多线程并发控制：Java并发工具包实战实例-蒲公英云

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

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

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

线程池：
```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(); // 安排所有等待的线程继续执行

原子操作工具：

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中使用多线程并发控制工具。