Java并发工具类简介及实战示例

原创骑猪看日落 2024-09-22 09:45 68阅读 0赞

在Java编程中，理解和使用各种并发工具类是提高程序效率和避免竞态条件的关键。以下是一些主要的Java并发工具类及其简介：

1. **java.util.concurrent**：
   - 这个包提供了大量的线程相关工具，如ExecutorService（线程池）、Callable（可执行任务）、Future（异步结果）等。

2. **java.util.concurrent.atomic**：
   - 这个包提供了一些原子操作类，如AtomicInteger、AtomicLong、AtomicReference等。这些类提供了无锁的读写操作，对于需要高并发和低延迟的应用非常有用。

实战示例：

1. 创建线程池并执行任务：

```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交多个任务到线程池中执行
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.submit(() -> {
                System.out.println("Task " + index + " is running by thread " + Thread.currentThread().getName());
                // 这里可以执行你的任务逻辑
            });
        }

// 关闭线程池，释放资源
        executor.shutdown();
    }
}
```

2. 使用Atomic类进行原子操作：

```java
import java.util.concurrent.atomic.AtomicInteger;

public class AtomicExample {
    public static void main(String[] args) {
        AtomicInteger counter = new AtomicInteger(0);

// 原子增加计数器的值
        counter.incrementAndGet();

// 检查更新后的计数器值
        System.out.println("Counter value: " + counter.get());

// 原子减小计数器的值
        counter.decrementAndGet();

// 再次检查更新后的计数器值
        System.out.println("Counter value after decrement: " + counter.get());
    }
}
```

以上示例展示了Java并发工具类的基本使用，包括创建线程池、提交任务、原子操作等。