详解Java的并发工具类：如何正确使用

原创女爷i 2024-12-07 23:36 13阅读 0赞

在Java中，并发工具类主要位于`java.util.concurrent`包下。这些工具类提供了创建线程池、管理定时任务、同步访问共享资源等功能，有助于提高程序的并发处理能力。

以下是一些常用并发工具类及其使用方法：

1. **线程池**：
```java
// 创建一个固定大小的线程池
ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池
executor.submit(() -> {
    // 这里是你的任务代码
}));

// 关闭线程池，所有提交的任务将被取消
executor.shutdown();
```

2. **定时任务**：
```java
// 创建一个ScheduledExecutorService实例
ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(1);

// 提交定时任务到线程池
scheduledExecutor.scheduleAtFixedRate(() -> {
    // 这里是你的定时任务代码
}), 0, 10_000); // 每隔10秒执行一次，持续10分钟

// 关闭ScheduledExecutorService实例
scheduledExecutor.shutdown();
```

3. **同步工具**：
```java
// 使用CountDownLatch实现多线程间的同步
CountDownLatch countDownLatch = new CountDownLatch(2);

// 线程A提交任务并等待B完成任务
new Thread(() -> {
    countDownLatch.countDown(); // 当计数器减少一个单位时，表示任务已开始

try {
        countDownLatch.await(10, TimeUnit.SECONDS)); // 如果在指定的时间内没有被唤醒，则线程会一直阻塞
        System.out.println("A的任务已完成，等待B的完成"); // 线程执行完成后的代码
    } catch (InterruptedException | TimeoutException e) {
        System.err.println("执行过程中出现错误：" + e.getMessage());
    }
})).start();

// 线程B提交任务并等待A完成任务
new Thread(() -> {
    countDownLatch.countDown(); // 当计数器减少一个单位时，表示任务已开始

try {
        countDownLatch.await(10, TimeUnit.SECONDS)); // 如果在指定的时间内没有被唤醒，则线程会一直阻塞
        System.out.println("B的任务已完成，等待A的完成"); // 线程执行完成后的代码
    } catch (InterruptedException | TimeoutException e) {
        System.err.println("执行过程中出现错误：" + e.getMessage());
    }
})).start();

// 在这里观察控制台输出，了解线程间的同步情况
```

以上就是Java中一些常用的并发工具类以及使用方法的简要概述。在实际项目开发中，根据具体的场景和需求，会选择合适的工具类进行编程。