java 创建线程问题 在线等待!

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java 创建线程问题 在线等待!相关的知识,希望对你有一定的参考价值。

创建线程有两种方法,一种是继承Thread类的方法,第二是创建线程,使用了实现了Runnable接口的方法。对比创建线程的两种方法,各有什么优点?
A. 实现Runnable接口比继承Thread类的方法要复杂;
B. 接口方法实现的是真正的多线程,而继承方法实现的不是真正的多线程;
C. 继承方法实现的是真正的多线程,而接口方法实现的不是真正的多线程;
D. 如果线程类要继承其它类,那么就必须用接口的方法来实现;
E. 二者在运行方面并无差别;
个人感觉选BDE

DE
B和C都是错的,实现Runnable接口和继承Thread都是真正的多线程
道理很简单,Thread类本身就实现了Runnable接口,
继承Thread类不就等于间接性实现Runnable接口了吗,
所以他们都是真正的多线程
参考技术A DE

Java线程池主线程等待子线程的方法

文章目录


事先声明:
1 以下案例均使用线程池创建线程。方便起见使用Executors.newFixedThreadPool()方法创建一个固定大小的线程池。
2 Runnable使用Lambda表达式创建
3 代码在main()方法中执行,出于方便演示,代码中有几处不规范的地方。

1. 轮询判断

思路:所有任务提交后,调用线程池的shutdown()方法,然后在死循环里每隔几秒调用一次线程池的isTerminated()方法,判断所有线程在线程池关闭后是否都已完成。需要注意的是调用isTerminated()前一定要先调用shutdown()或shutdownNow()方法,原因可以在isTerminated()的源码中找到,位于java.util.concurrent.ExecutorService 198行左右,内容如下:

翻译为中文:如果所有任务在关闭后都已完成,则返回 true。请注意,除非首先调用了 shutdown 或 shutdownNow,否则 isTerminated 永远不会为真。

实现代码:

public static void main(String[] args) throws Exception 
    int n = 3;
    String[] tasks = "发送短信消息完毕", "发送微信消息完毕", "发送邮箱消息完毕";
    int[] executeTimes = new int[]2, 5, 1;
    ExecutorService threadPool = Executors.newFixedThreadPool(n);
    long start = System.currentTimeMillis();

    for (int i = 0; i < n; i++) 
        int finalI = i;
        threadPool.execute(() -> 
            try 
                TimeUnit.SECONDS.sleep(executeTimes[finalI]);
             catch (InterruptedException e) 
                e.printStackTrace();
            
            System.out.println(tasks[finalI]);
        );
    
    // 以下为关键代码
    threadPool.shutdown();
    while (true) 
        if (threadPool.isTerminated()) 
            break;
         else 
            TimeUnit.SECONDS.sleep(1);
        
    
    System.out.println("所有消息都发送完毕了,继续执行主线程任务。\\n耗时ms:" + (System.currentTimeMillis() - start));

此处每隔1s判断一次

2. 使用CountDownLatch(推荐)

CountDownLatch是JUC提供的解决方案
CountDownLatch 可以保证一组子线程全部执行完牛后再进行主线程的执行操作。例如,主线程启动前,可能需要启动并执行若干子线程,这时就可以通过 CountDownLatch 来进行控制。
CountDownLatch是通过一个线程个数的计数器实现的同步处理操作,在初始化时可以为CountDownLatch设置一个线程执行总数,这样每当一个子线程执行完毕后都要执行减1操作,当所有的子线程都执行完毕后,CountDownLatch中保存的计数为0,则主线程恢复执行。

CountDownLatch类常用方法

方法描述
public CountDownLatch(int count)定义等待子线程总数
public void await() throws InterruptedException主线程阻塞,等待子线程执行完毕
public void countDown()子线程执行完后减少等待数量
public long getCount()获取当前等待数量

实现代码:

public static void main(String[] args) throws Exception 
    int n = 3;
    String[] tasks = "发短信完毕", "发微信完毕", "发QQ完毕";
    int[] executeTimes = new int[]2, 5, 1;
    CountDownLatch countDownLatch = new CountDownLatch(n);
    ExecutorService executorService = Executors.newFixedThreadPool(n);

    long start = System.currentTimeMillis();
    for (int i = 0; i < n; i++) 
        int finalI = i;
        executorService.submit(() -> 
            try 
                TimeUnit.SECONDS.sleep(executeTimes[finalI]);
                System.out.println(tasks[finalI]);
             catch (InterruptedException e) 
                e.printStackTrace();
             finally 
                countDownLatch.countDown();
            
        );
    
    countDownLatch.await();
    System.out.println("所有消息都发送完毕了,继续执行主线程任务。\\n耗时ms:" + (System.currentTimeMillis() - start));
    // 不要忘记关闭线程池,不然会导致主线程阻塞无法退出
    executorService.shutdown();

本程序利用 CountDownLatch 定义了要等待的子线程数量,这样在该统计数量不为0的时候,主线代码暂时挂起,直到所有的子线程执行完毕(调用countDown()方法)后主线程恢复执行。

3. 使用CyclicBarrier

待补充 …

以上是关于java 创建线程问题 在线等待!的主要内容,如果未能解决你的问题,请参考以下文章

java 创建线程池的4中方式

Java线程池主线程等待子线程的方法

Java线程池主线程等待子线程的方法

Java线程池主线程等待子线程的方法

Java线程池

Java 并发编程 -- 并发编程线程基础(线程创建与运行线程通知与等待join / sleep / yield方法线程中断线程上下文切换死锁守护线程与用户线程ThreadLocal)