解决并发编程中的问题：Java线程通信示例

原创深藏阁楼爱情的钟 2024-10-11 20:45 59阅读 0赞

在Java中，线程间的通信主要是通过共享变量、消息队列或者Java的特定API进行的。

以下是几种常见的线程通信方式的示例：

1. 共享变量：
```java
class Counter {
    private int count = 0;

public synchronized void increment() {
        count++;
        notifyAll();
    }

public synchronized int decrement() {
        if (count > 0) {
            count--;
            notifyAll();
        }
        return count;
    }

public synchronized int getCount() {
        return count;
    }
}

// 创建线程
class IncrementThread extends Thread {
    private Counter counter;

public IncrementThread(Counter counter) {
        this.counter = counter;
    }

@Override
    public void run() {
        for (int i = 0; i < 10; i++) {
            counter.increment();
            try {
                // 线程睡眠一段时间，模拟耗时操作
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Main {
    public static void main(String[] args) {
        Counter counter = new Counter();

// 创建并启动线程
        IncrementThread incrementThread = new IncrementThread(counter);
        incrementThread.start();

try {
            // 线程等待直到计数达到10
            while (counter.getCount() < 10) {
                Thread.sleep(50);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Counter count: " + counter.getCount());

// 关闭共享对象，确保线程安全
        counter = null;
    }
}
```
上述代码创建了一个共享的`Counter`类，并使用它来协调两个线程（一个递增，一个等待）。通过这种方式，你可以理解Java中如何进行线程通信。