for循环使用多线程并查看执行结果

待我称王封你为后i 2023-07-06 06:17 19阅读 0赞

直接上代码

import java.util.concurrent.*;
    
    public class ThreadDemo { 
        public static void main(String[] args) throws Exception { 
            // 1.创建线程池
            ExecutorService executorService = Executors.newFixedThreadPool(5);
            // 2.定义CompletionService
            CompletionService<String> service = new ExecutorCompletionService<>(executorService);
            // 3.添加任务
            for (int i = 0; i < 10; i++) { 
                //普通写法
                /*service.submit(new Callable<String>() { public String call() { return "线程：" + Thread.currentThread().getName() + "执行完成"; } });*/
                // lambda写法
                service.submit(() -> "线程：" + Thread.currentThread().getName() + "执行完成");
            }
            // 4.获取结果
            for (int i = 0; i <= 10; i++) { 
                System.out.println(service.take().get());
            }
            // 关闭线程池
            executorService.shutdown();
        }
    }

运行结果  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNTQ4NzQx_size_16_color_FFFFFF_t_70]

> ExecutorCompletionService实现了CompletionService接口,  
> 在CompletionService接口中定义了如 下这些方法:
> 
>  *  Future submit(Callable task):提交一个Callable类型任务 ,并返回该任务执行结果关联 的Future ;
>  *  Future submit(Runnable task,V result):提交- 个Runnable类型任务,并返回该任务执行结 果关联的Future ;
>  *  Future take():从内部阻塞队列中获取并移除第一个执行完成的任务,阻塞,直到有任务完 成;
>  *  Future pol():从内部阻塞队列中获取并移除第一个执行完成的任务 ,获取不到则返回null， 不阻塞;
>  *  Future poll(long timeout, TimeUnit unit):从内部阻塞队列中获取并移除第一 个执行完成的任 务,阻塞时间为timeout ,获取不到则返回null ;

我这里使用了Lambda表达式取代了匿名内部类,推荐使用,很方便.

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNTQ4NzQx_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200216175354373.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwNTQ4NzQx,size_16,color_FFFFFF,t_70