Java 里如何实现线程间通信
正常情况下,每个子线程完成各自的任务就可以结束了。不过有的时候,我们希望多个线程协同工作来完成某个任务,这时就涉及到了线程间通信了。
本文涉及到的知识点:thread.join(), object.wait(), object.notify(), CountdownLatch, CyclicBarrier, FutureTask, Callable 等。
下面我从几个例子作为切入点来讲解下 Java 里有哪些方法来实现线程间通信。
- 如何让两个线程依次执行?
- 那如何让 两个线程按照指定方式有序交叉运行呢?
- 四个线程 A B C D,其中 D 要等到 A B C 全执行完毕后才执行,而且 A B C 是同步运行的
- 三个运动员各自准备,等到三个人都准备好后,再一起跑
- 子线程完成某件任务后,把得到的结果回传给主线程
如何让两个线程依次执行?
假设有两个线程,一个是线程 A,另一个是线程 B,两个线程分别依次打印 1-3 三个数字即可。我们来看下代码:
private static void demo1() { Thread A = new Thread(new Runnable() { @Override public void run() { printNumber("A"); } }); Thread B = new Thread(new Runnable() { @Override public void run() { printNumber("B"); } }); A.start(); B.start(); }
其中的 printNumber(String) 实现如下,用来依次打印 1, 2, 3 三个数字:
private static void printNumber(String threadName) { int i=0; while (i++ < 3) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(threadName + "print:" + i); } }
这时我们得到的结果是:
B print: 1 A print: 1 B print: 2 A print: 2 B print: 3 A print: 3
得到的结果如下:
B 开始等待 A A print: 1 A print: 2 A print: 3 B print: 1 B print: 2 B print: 3
打印结果如下:
A 1 A waiting… B 1 B 2 B 3 A 2 A 3
打印结果如下:
INFO: A 等待锁 INFO: A 得到了锁 lock A 1 INFO: A 准备进入等待状态,调用 lock.wait() 放弃锁 lock 的控制权 INFO: B 等待锁 INFO: B 得到了锁 lock B 1 B 2 B 3 INFO: B 打印完毕,调用 lock.notify() 方法 INFO: 有人唤醒了 A, A 重新获得锁 lock A 2 A 3
下面是运行结果:
D is waiting for other three threads A is working B is working C is working A finished C finished B finished All done, D starts working
打印的结果如下:
A is preparing for time: 4131 B is preparing for time: 6349 C is preparing for time: 8206 A is prepared, waiting for others B is prepared, waiting for others C is prepared, waiting for others C starts running A starts running B starts running
可以看到 run() 在执行完后不会返回任何结果。那如果希望返回结果呢?这里可以利用另一个类似的接口类 Callable:
@FunctionalInterface public interface Callable<V> { /** * Computes a result, or throws an exception if unable to do so. * * @return computed result * @throws Exception if unable to compute a result */ V call() throws Exception; }
可以看出 Callable 最大区别就是返回范型 V 结果。
那么下一个问题就是,如何把子线程的结果回传回来呢?在 Java 里,有一个类是配合 Callable 使用的:FutureTask,不过注意,它获取结果的 get 方法会阻塞主线程。
举例,我们想让子线程去计算从 1 加到 100,并把算出的结果返回到主线程。
private static void doTaskWithResultInWorker() { Callable<Integer> callable = new Callable<Integer>() { @Override public Integer call() throws Exception { System.out.println("Task starts"); Thread.sleep(1000); int result = 0; for (int i=0; i<=100; i++) { result += i; } System.out.println("Task finished and return result"); return result; } }; FutureTask<Integer> futureTask = new FutureTask<>(callable); new Thread(futureTask).start(); try { System.out.println("Before futureTask.get()"); System.out.println("Result:" + futureTask.get()); System.out.println("After futureTask.get()"); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } }
打印结果如下:
Before futureTask.get() Task starts Task finished and return result Result: 5050 After futureTask.get()
可以看到,主线程调用 futureTask.get() 方法时阻塞主线程;然后 Callable 内部开始执行,并返回运算结果;此时 futureTask.get() 得到结果,主线程恢复运行。
这里我们可以学到,通过 FutureTask 和 Callable 可以直接在主线程获得子线程的运算结果,只不过需要阻塞主线程。当然,如果不希望阻塞主线程,可以考虑利用 ExecutorService,把 FutureTask 放到线程池去管理执行。
小结
多线程是现代语言的共同特性,而线程间通信、线程同步、线程安全是很重要的话题。本文针对 Java 的线程间通信进行了大致的讲解,后续还会对线程同步、线程安全进行讲解。
- Java 里如何实现线程间通信
- 浅析Java中如何实现线程之间通信
- Java 里如何实现线程间通信
- Java 里如何实现线程间通信?
- Java 里如何实现线程间通信
- java学习——如何实现线程之间的通信 ,Condition 的使用
- Java 里如何实现线程间通信
- Java 里如何实现线程间通信?
- Java 里如何实现线程间通信
- Java 里如何实现线程间通信
- Java 里如何实现线程间通信?
- Java里如何实现线程间通信?
- Java里如何实现线程间通信?
- Java里如何实现线程间通信?
- Java 里如何实现线程间通信
- Java里如何实现线程间通信
- java如何实现启动一个线程
- 黑马程序员——JAVA基础---线程之间的通信实现交替输出打印
- java如何实现多个线程并发运行
- 拿来主义:java中的线程安全与非线程安全,以及如何使用和实现