如何确保三个线程顺序执行

墨蓝 2023-06-12 08:55 16阅读 0赞

场景：有三个线程t1、t2、t3。确保三个线程t1执行完后t2执行，t2执行完成后t3执行。

1、thread.Join把指定的线程加入到当前线程，可以将两个交替执行的线程合并为顺序执行的线程。比如在线程B中调用了线程A的Join()方法，直到线程A执行完毕后，才会继续执行线程B

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 </td> 
 <td> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>ThreadTest1&nbsp;{ </code> <code>//&nbsp;T1、T2、T3三个线程顺序执行</code> <code>public</code>&nbsp;<code>static</code>&nbsp;<code>void</code>&nbsp;<code>main(String[]&nbsp;args)&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread&nbsp;t1&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>Thread(</code><code>new</code>&nbsp;<code>Work(</code><code>null</code><code>));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread&nbsp;t2&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>Thread(</code><code>new</code>&nbsp;<code>Work(t1));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread&nbsp;t3&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>Thread(</code><code>new</code>&nbsp;<code>Work(t2));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>t1.start();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>t2.start();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>t3.start();</code> <code>&nbsp;</code>&nbsp; <code>}</code> <code>static</code>&nbsp;<code>class</code>&nbsp;<code>Work&nbsp;</code><code>implements</code>&nbsp;<code>Runnable&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>Thread&nbsp;beforeThread;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>Work(Thread&nbsp;beforeThread)&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.beforeThread&nbsp;=&nbsp;beforeThread;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>run()&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code>&nbsp;<code>(beforeThread&nbsp;!=&nbsp;</code><code>null</code><code>)&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>beforeThread.join();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"thread&nbsp;start:"</code>&nbsp;<code>+&nbsp;Thread.currentThread().getName());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(InterruptedException&nbsp;e)&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>e.printStackTrace();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>else</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"thread&nbsp;start:"</code>&nbsp;<code>+&nbsp;Thread.currentThread().getName());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

2、使用CountDownLatch

CountDownLatch(闭锁)是一个很有用的工具类，利用它我们可以拦截一个或多个线程使其在某个条件成熟后再执行。它的内部提供了一个计数器，在构造闭锁时必须指定计数器的初始值，且计数器的初始值必须大于0。另外它还提供了一个countDown方法来操作计数器的值，每调用一次countDown方法计数器都会减1，直到计数器的值减为0时就代表条件已成熟，所有因调用await方法而阻塞的线程都会被唤醒。这就是CountDownLatch的内部机制，看起来很简单，无非就是阻塞一部分线程让其在达到某个条件之后再执行。

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 </td> 
 <td> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>ThreadTest2&nbsp;{ </code> <code>&nbsp;</code>&nbsp; <code>//&nbsp;T1、T2、T3三个线程顺序执行</code> <code>public</code>&nbsp;<code>static</code>&nbsp;<code>void</code>&nbsp;<code>main(String[]&nbsp;args)&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>CountDownLatch&nbsp;c0&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>CountDownLatch(</code><code>0</code><code>);&nbsp;</code><code>//计数器为0</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>CountDownLatch&nbsp;c1&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>CountDownLatch(</code><code>1</code><code>);&nbsp;</code><code>//计数器为1</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>CountDownLatch&nbsp;c2&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>CountDownLatch(</code><code>1</code><code>);&nbsp;</code><code>//计数器为1</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread&nbsp;t1&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>Thread(</code><code>new</code>&nbsp;<code>Work(c0,&nbsp;c1));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//c0为0，t1可以执行。t1的计数器减1</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread&nbsp;t2&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>Thread(</code><code>new</code>&nbsp;<code>Work(c1,&nbsp;c2));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//t1的计数器为0时，t2才能执行。t2的计数器c2减1</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread&nbsp;t3&nbsp;=&nbsp;</code><code>new</code>&nbsp;<code>Thread(</code><code>new</code>&nbsp;<code>Work(c2,&nbsp;c2));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//t2的计数器c2为0时，t3才能执行</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>t1.start();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>t2.start();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>t3.start();</code> <code>&nbsp;</code>&nbsp; <code>}</code> <code>&nbsp;</code>&nbsp; <code>//定义Work线程类，需要传入开始和结束的CountDownLatch参数</code> <code>static</code>&nbsp;<code>class</code>&nbsp;<code>Work&nbsp;</code><code>implements</code>&nbsp;<code>Runnable&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>CountDownLatch&nbsp;c1;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>CountDownLatch&nbsp;c2;</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Work(CountDownLatch&nbsp;c1,&nbsp;CountDownLatch&nbsp;c2)&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>super</code><code>();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.c1&nbsp;=&nbsp;c1;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.c2&nbsp;=&nbsp;c2;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>run()&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code>&nbsp;<code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>c1.await();</code><code>//前一线程为0才可以执行</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"thread&nbsp;start:"</code>&nbsp;<code>+&nbsp;Thread.currentThread().getName());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>c2.countDown();</code><code>//本线程计数器减少</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;</code><code>catch</code>&nbsp;<code>(InterruptedException&nbsp;e)&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>