新手困惑：Java多线程通信问题实例

原创超、凢脫俗 2024-11-14 12:21 6阅读 0赞

在Java多线程编程中，有效的通信是必不可少的。以下是一个具体的例子，我们将创建两个线程，一个生产任务，另一个消费任务，实现简单的消息传递。

1. 创建生产和消费的类：

```java
public class ThreadExample {
    private final Object lock = new Object();

// 生产者线程
    public void producerThread() {
        for (int i = 0; i < 10; i++) {
            synchronized (lock) {
                System.out.println("生产任务：" + i);
                lock.notifyAll(); // 唤醒所有等待的线程
            }
        }
    }

// 消费者线程
    public void consumerThread() {
        while (true) {
            synchronized (lock) {
                if (!lock.wait(100))) { // 如果等待时间过期，线程将被中断
                    System.out.println("消费者任务超时中断");
                    return;
                }
                System.out.println("消费任务：" + lock.get());
                lock.notifyAll(); // 唤醒所有等待的线程
            }
        }
    }

public static void main(String[] args) {
        ThreadExample example = new ThreadExample();
        Thread producerThread = new Thread(example::producerThread);
        Thread consumerThread = new Thread(example::consumerThread);

producerThread.start(); // 开始生产任务
        consumerThread.start(); // 开始消费任务

try {
            producerThread.join(); // 等待生产任务完成
            consumerThread.join(); // 等待消费任务完成
            System.out.println("所有线程已完成");
        } catch (InterruptedException e) {
            e.printStackTrace();
            System.out.println("主线程中断");
        }
    }
}
```

在这个例子中，一个生产者线程（producerThread）负责生成任务，这些任务在一个共享的锁（lock）上进行同步。消费者线程（consumerThread）则负责消费这些任务。

通过这种方式，生产者和消费者可以有效地通信，实现多线程之间的协作。