在Java中如何实现线程间安全通信

答案:Java中线程安全通信需保证可见性、原子性和有序性,常用synchronized实现同步与wait/notify协作,ReentrantLock结合Condition提供更灵活控制,BlockingQueue适用于生产者-消费者模型,volatile确保变量可见性,原子类如AtomicInteger实现无锁安全操作。

在Java中实现线程间安全通信,核心是保证数据共享时的可见性、原子性和有序性。主要手段包括使用同步机制、并发工具类和线程安全的数据结构。以下是几种常见且有效的实现方式。

使用synchronized关键字

synchronized 是最基础的线程同步机制,可确保同一时刻只有一个线程能执行特定代码块或方法。

它适用于多个线程操作同一资源的场景,比如两个线程交替打印奇偶数:

- 用 synchronized 修饰方法或代码块,配合 wait() 和 notify()/notifyAll() 实现线程协作。
- 一个线程调用 wait() 进入等待状态,另一个线程处理完后调用 notify() 唤醒等待线程。
- 必须在同步块内调用 wait/notify,否则会抛出异常。

使用ReentrantLock与Condition

相比 synchronized,ReentrantLock 提供了更灵活的锁控制,结合 Condition 可实现精确的线程等待与唤醒。

- Lock 可以创建多个 Condition 实例,不同线程可以等待不同的条件。
- 支持公平锁、可中断等待、超时获取锁等高级特性。
- 使用 lock() 获取锁,unlock() 释放锁,必须放在 try-finally 中防止死锁。

使用阻塞队列(BlockingQueue)

Java并发包提供了多种线程安全的阻塞队列,如 ArrayBlockingQueueLinkedBlockingQueue,非常适合生产者-消费者模型。

- put() 方法在队列满时阻塞,take() 在队列空时阻塞。
- 多个生产者和消费者可安全地并发操作队列。
- 无需手动加锁,队列内部已实现线程安全。

使用volatile关键字与原子类

当仅需保证变量的可见性而非复合操作原子性时,volatile 是轻量级选择。

- volatile 保证变量修改对其他线程立即可见,但不保证原子性。
- 对于计数、状态标志等简单场景,可结合 volatile 和 CAS 操作。
- 更推荐使用 java.util.concurrent.atomic 包下的原子类,如 AtomicInteger、AtomicBoolean,它们通过 CAS 实现无锁

线程安全。

基本上就这些。根据具体场景选择合适的方式:简单同步用 synchronized,复杂协作选 Lock + Condition,数据传递优先考虑 BlockingQueue,状态或计数用原子类。安全通信的关键是避免竞态条件,合理利用Java并发工具能大幅降低出错概率。