多线程编程困惑：Java并发工具箱使用案例

原创心已赠人 2024-10-21 21:15 43阅读 0赞

在Java中，我们常常会用到Java并发工具箱（java.util.concurrent）提供的各种线程相关工具。下面是一些常用的使用案例：

1. **创建线程**：
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadExample {
    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());
                try {
                    // 模拟耗时操作
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + index + " completed.");
            });
        }

// 关闭线程池，不再接受新的任务
        executor.shutdown();

// 等待所有任务完成或者线程池关闭超时
        while (!executor.isTerminated()) {
            try {
                // 如果需要处理其他业务，可以在这里暂停执行
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All tasks completed.");
    }
}
```
2. **同步工具**：
- **`Semaphore`(信号量)**：控制同时访问资源的线程数。
```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    public static void main(String[] args) {
        // 创建一个信号量，初始值为5
        Semaphore semaphore = new Semaphore(5);

// 提交多个任务到信号量上执行
        for (int i = 0; i < 10; i++) {
            final int index = i;
            semaphore.acquire(); // 获取信号量的许可

try {
                System.out.println("Task " + index + " is running by thread: " + Thread.currentThread().getName());
                // 模拟耗时操作
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
                semaphore.release(); // 释放信号量许可，表示任务中断或完成
            } finally {
                semaphore.release(); // 自动释放信号量许可，表示任务执行完毕
            }
        }

System.out.println("All tasks completed.");
    }
}
```
3. **线程池**：
- ``ThreadPoolExecutor`(线程池)`：用于管理一组工作线程的工具。
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，大小为5
        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());
                // 模拟耗时操作
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + index + " completed.");
            });
        }

// 关闭线程池，不再接受新的任务
        executor.shutdown();

System.out.println("All tasks completed.");
    }
}
```
以上就是Java并发工具箱的基本使用案例。在实际项目中，根据需求选择合适的并发工具进行使用。