java多线程通信代码示例（wait notify synchronized）

迈不过友情╰ 2024-02-18 13:44 64阅读 0赞

下面是一个简单的Java多线程通信的示例代码，使用`wait()`、`notify()`和`synchronized`关键字实现线程间的协调和通信：

public class ThreadCommunicationExample {
        
        public static void main(String[] args) {
        
            final Processor processor = new Processor();
    
            // 线程1负责生产数据
            Thread producerThread = new Thread(() -> {
        
                try {
        
                    processor.produce();
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                }
            });
    
            // 线程2负责消费数据
            Thread consumerThread = new Thread(() -> {
        
                try {
        
                    processor.consume();
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                }
            });
    
            // 启动线程
            producerThread.start();
            consumerThread.start();
        }
    }
    
    class Processor {
        
        public void produce() throws InterruptedException {
        
            synchronized (this) {
        
                System.out.println("Producer线程开始生产数据...");
                
                // 模拟生产过程
                Thread.sleep(2000);
                
                System.out.println("Producer线程生产数据完成，通知Consumer线程消费...");
                notify(); // 通知等待中的线程可以继续执行
                
                // 模拟其他操作
                Thread.sleep(1000);
            }
        }
    
        public void consume() throws InterruptedException {
        
            synchronized (this) {
        
                // Consumer等待Producer生产数据
                System.out.println("Consumer线程等待生产数据...");
                wait(); // 等待Producer线程通知可以继续执行
    
                // 被唤醒后继续执行
                System.out.println("Consumer线程开始消费数据...");
                
                // 模拟消费过程
                Thread.sleep(2000);
                
                System.out.println("Consumer线程消费数据完成...");
            }
        }
    }

在上述示例中，`Processor`类表示数据处理器，其中的`produce()`方法负责生产数据，`consume()`方法负责消费数据。

在`produce()`方法中，使用`synchronized`关键字获取对象锁，确保只有一个线程可以进入临界区。首先，生产者线程开始生产数据，然后通过`notify()`方法通知等待中的消费者线程可以继续执行。最后，模拟其他操作，并将线程休眠一段时间。

在`consume()`方法中，同样使用`synchronized`关键字获取对象锁。消费者线程首先等待生产者线程生产数据，通过`wait()`方法释放对象锁并进入等待状态。一旦收到生产者线程的通知，消费者线程被唤醒，继续执行消费数据的操作，最后将线程休眠一段时间。

通过`synchronized`、`wait()`和`notify()`的组合，生产者和消费者线程实现了协调和通信，确保在适当的时机进行生产和消费操作。

请注意，上述示例只是一个简单的演示，实际的多线程通信可能涉及更复杂的逻辑和数据交互。在实际应用中，还应该考虑线程安全、死锁避免等方面的问题，并根据具体需求选择适当的线程通信机制。