Java多线程通信问题实例展示

原创我不是女神ヾ 2024-11-26 07:36 12阅读 0赞

在Java中，多线程通信主要通过以下几种方式实现：

1. synchronized关键字：在同步方法或者代码块内部，同一时间只有一个线程可以执行。

```java
public class Counter {
    private int count = 0;

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

public synchronized int decrement() {
        if (count > 0) {
            count--;
            notifyAll();
            return count; // 返回减少后的值
        } else {
            throw new IllegalArgumentException("Counter is already zero");
        }
    }
}
```

2. volatile关键字：用于保证多线程环境下变量的可见性，但不能保证原子性。

```java
public class CounterVolatile {
    private int count = 0;

public void increment() {
        while (true) { // 使用循环避免并发问题
            if (count != volatileCount) { // 通过volatile关键字获取可见状态
                count++;
                break;
            }
            try { // 线程休眠，降低资源消耗
                Thread.sleep(10); // 休眠10毫秒，模拟实际操作场景
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

public int decrement() {
        if (count > 0) {
            count--;
            return count;
        } else {
            throw new IllegalArgumentException("Counter is already zero");
        }
    }
}
```

3. 呈现线程通信的完整应用场景：例如一个生产任务，多个生产线（线程）并行执行，通过共享数据结构（如计数器）来协调任务完成情况。

```java
public class Factory {
    private static final int MAX_PRODUCTS = 100;
    private int productsProduced;

public synchronized void startProduction(int numberOfLines) {
        if (numberOfLines > MAX_PRODUCTS) {
            throw new IllegalArgumentException("Number of lines exceeds maximum capacity");
        }
        for (int i = 0; i < numberOfLines; i++) {
            productsProduced++;
            notifyAll(); // 唤醒等待的线程
        }
    }

public synchronized int getProductsProduced() {
        return productsProduced;
    }
}
```

以上就是Java多线程通信问题实例展示。