线程间消息传递推荐使用BlockingQueue,如ArrayBlockingQueue,通过put/take实现生产者-消费者模式;2. 可用PipedInputStream/PipedOutputStream进行线程间流通信,但较底层不常用;3. join()结合volatile可实现线程完成通知与结果传递。

在Java中,线程间的消息传递主要依赖于明确的通信机制,避免直接操作共享变量。这种方式更安全、清晰,尤其适合复杂的并发场景。
使用阻塞队列(BlockingQueue)
这是最常用且推荐的方式,特别适用于“生产者-消费者”模式。BlockingQueue 是线程安全的队列,当队列为空时,消费者线程调用 take() 会自动阻塞;当队列满时,生产者线程调用 put() 也会阻塞,直到有空间可用。
常见的实现类有 ArrayBlockingQueue、LinkedBlockingQueue 和 PriorityBlockingQueue。
- put(E e):将元素插入队列,如果队列满,则等待。
- take():从队列获取并移除一个元素,如果队列空,则等待。
- offer(E e, long timeout, TimeUnit unit):带超时的插入。
- poll(long timeout, TimeUnit unit):带超时的获取。
这种方式无需手动管理锁和条件变量,大大简化了代码逻辑。
立即学习“Java免费学习笔记(深入)”;
使用管道流(PipedInputStream/PipedOutputStream)
Java 提供了管道流机制,允许一个线程的输出作为另一个线程的输入,类似于进程间的管道通信。
- 一个线程通过 PipedOutputStream 写入数据。
- 另一个线程通过 PipedInputStream 读取数据。
- 需要将输入流和输出流连接起来,例如 new PipedInputStream(pos)。
这种方式比较底层,通常用于模拟 I/O 流的场景,日常开发中不如 BlockingQueue 常用。
利用 join() 方法进行同步通知
虽然 join() 主要用于线程同步,但它也可以看作一种简单的消息传递。主线程调用子线程的 join() 方法后会阻塞,直到子线程执行完毕,这相当于子线程向主线程发送了“已完成”的信号。
结合 volatile 变量或共享状态,可以在子线程结束前设置结果,主线程在 join() 返回后立即读取,实现结果传递。
基本上就这些










