并发编程挑战：Java线程通信示例

原创红太狼 2024-09-21 18:18 103阅读 0赞

在Java中，线程间的通信是通过共享资源（如变量、数组、锁对象等）或者特定的通信机制实现的。下面是一个简单的线程通信示例：

1. **创建共享资源**：
```java
public class SharedResource {
    private int count = 0;

public synchronized void increment() {
        count++;
        notifyAll(); // 提醒等待的线程
    }

public synchronized int getCount() {
        return count;
    }
}
```
2. **创建并启动线程**：
```java
public class ThreadCommunicationExample {
    private SharedResource resource = new SharedResource();

public void startIncrementThread() {
        new Thread(() -> {
            while (true) { // 无限循环等待通知
                try {
                    resource.increment(); // 增加资源
                    break; // 离开循环，执行其他任务
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    return; // 结束线程
                }
            }
        })).start(); // 启动线程
    }

public void startCountThread() {
        new Thread(() -> {
            while (true) {
                try {
                    int count = resource.getCount(); // 获取资源当前值
                    System.out.println("Count: " + count);
                    if (count == 10) { // 当资源值达到特定条件时执行操作
                        System.out.println("Resource value reached, stopping increment thread.");
                        break; // 离开循环，结束线程
                    }
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    return; // 结束线程
                }
            }
        })).start(); // 启动线程
    }

public static void main(String[] args) {
        ThreadCommunicationExample example = new ThreadCommunicationExample();
        example.startIncrementThread(); // 开始增加资源的线程
        example.startCountThread(); // 开始计数资源值的线程
    }
}
```
3. **运行示例**：通过`main`方法启动这个例子，你会看到两个线程分别执行增加资源和计数资源值的操作。