线程间通信的核心是协调执行顺序和共享数据,主要通过共享内存与同步机制实现。常用方式包括:使用wait()、notify()在synchronized中实现基础通信,适用于生产者-消费者模型;ReentrantLock配合Condition提供更精准的等待唤醒控制;BlockingQueue封装了线程安全与阻塞操作,简化生产者-消费者场景开发;此外还可选用CountDownLatch、CyclicBarrier等工具满足特定需求。选择依据为:简单场景用wait/notify,复杂控制用ReentrantLock+Condition,生产者-消费者优先使用BlockingQueue。

在Java中,线程间通信的核心是协调多个线程之间的执行顺序和数据共享。主要通过共享内存结合同步机制来实现,常用的方式包括wait()、notify()、notifyAll()、ReentrantLock配合Condition,以及使用BlockingQueue等并发工具类。
使用 wait() 和 notify() 实现线程通信
这是最基础的线程通信方式,基于对象锁(synchronized)实现。一个线程调用wait()进入等待状态,另一个线程调用notify()或notifyAll()唤醒等待线程。
注意:wait()和notify()必须在synchronized块或方法中调用,否则会抛出异常。
- 生产者线程在缓冲区满时调用
wait(),释放锁并等待 - 消费者线程消费后调用
notify(),唤醒生产者继续生产 - 同理,缓冲区为空时消费者等待,生产者生产后唤醒消费者
使用 ReentrantLock 和 Condition
ReentrantLock提供了比synchronized更灵活的锁控制,配合Condition可以实现更精确的线程等待与唤醒。
立即学习“Java免费学习笔记(深入)”;
每个Condition对象代表一个等待队列,可创建多个Condition实现不同条件的等待/通知,避免了notify()随机唤醒的问题。
在现实生活中的购物过程,购物者需要先到商场,找到指定的产品柜台下,查看产品实体以及标价信息,如果产品合适,就将该产品放到购物车中,到收款处付款结算。电子商务网站通过虚拟网页的形式在计算机上摸拟了整个过程,首先电子商务设计人员将产品信息分类显示在网页上,用户查看网页上的产品信息,当用户看到了中意的产品后,可以将该产品添加到购物车,最后使用网上支付工具进行结算,而货物将由公司通过快递等方式发送给购物者
- 调用
lock()获取锁 - 通过
newCondition()创建Condition实例 - 需要等待时调用
condition.await() - 满足条件后调用
condition.signal()或signalAll()唤醒指定线程
使用 BlockingQueue 实现线程通信
BlockingQueue是java.util.concurrent包中的阻塞队列,内部已封装了线程安全和等待/通知机制,非常适合生产者-消费者场景。
常见实现有ArrayBlockingQueue、LinkedBlockingQueue等。
- 无需手动处理
wait/notify - 提供超时操作如
offer()、poll() - 代码简洁,不易出错
其他通信方式
除了上述主流方式,还可以使用:
-
CountDownLatch:让一个或多个线程等待其他线程完成操作 -
CyclicBarrier:多个线程互相等待到达某个屏障点 -
PipedInputStream/PipedOutputStream:通过管道进行线程间数据传输(较少使用)
基本上就这些。选择哪种方式取决于具体需求:简单场景可用wait/notify,复杂控制推荐ReentrantLock + Condition,而生产者-消费者优先考虑BlockingQueue。









