多线程并发控制：Java并发工具包实战实例

原创刺骨的言语ヽ痛彻心扉 2024-09-27 13:06 100阅读 0赞

在Java中，多线程并发控制是非常关键的一部分。Java提供了一个强大的并发工具包——java.util.concurrent和java.util.concurrent.atomic。

下面是一些Java并发工具包实战实例：

1. **线程池**：
```java
// 创建一个固定大小的线程池
ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 2, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5)); // 线程池提交任务

executor.execute(new Runnable() {
    @Override
    public void run() {
        System.out.println("Task executed by thread: " + Thread.currentThread().getName());
    }
}));

executor.shutdown(); // 关闭线程池
```

2. **同步工具**：
- `synchronized`关键字用于实现互斥锁（Lock）。
```java
class Counter {
    private int count = 0;

synchronized void increment() {
        count++;
    }

synchronized int getCount() {
        return count;
    }
}

// 使用示例
Counter counter = new Counter();
counter.increment(); // 调用同步方法，互斥锁锁定
counter.increment(); // 同理，再次锁定互斥锁
System.out.println(counter.getCount()); // 输出：2

counter.decrement(); // 准备释放互斥锁（解锁）
System.out.println(counter.getCount()); // 可能输出：1 或 0（取决于释放顺序和资源状况）

counter.notifyAll(); // 安排所有等待的线程继续执行
```

3. **原子操作工具**：
- `java.util.concurrent.atomic`提供了一种声明单个原子变量的方法。
```java
import java.util.concurrent.atomic.AtomicInteger;

public class AtomicExample {
    private AtomicInteger count = new AtomicInteger(0);

public void increment() {
        count.incrementAndGet(); // 原子操作，不会被中断
    }

public int getCount() {
        return count.get(); // 获取原值
    }
}

// 使用示例
AtomicExample atomicExample = new AtomicExample();
atomicExample.increment(); // 原子操作，无需等待结果
System.out.println(atomicExample.getCount()); // 输出：1

atomicExample.decrement(); // 准备释放原子变量（解锁）
System.out.println(atomicExample.getCount())); // 可能输出：0 或 1（取决于释放顺序和资源状况）

atomicExample.notifyAll(); // 安排所有等待的线程继续执行
```

这些实例展示了如何在Java中使用多线程并发控制工具。