理解并解决Java并发问题：线程池案例

原创本是古典何须时尚 2024-12-06 11:45 22阅读 0赞

在Java中，线程池是一种管理线程资源的方式。通过预先创建一组工作线程，当有新的任务需要执行时，不再新创建线程，而是从线程池中获取可用的线程来执行任务。

下面是一个简单的线程池案例：

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

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

// 提交任务到线程池，这些任务会被线程池中的线程来执行
        for (int i = 0; i < 10; i++) {
            Runnable task = () -> System.out.println("Task " + i + " executed by thread " + Thread.currentThread().getId());
            executor.execute(task);
        }

// 关闭线程池，所有提交的任务都会等待当前正在执行的线程完成后再由线程池中的其他线程来执行
        executor.shutdown();
        try {
            // 确保线程池中没有活跃的线程（即所有任务都已完成）
            if (!executor.isTerminated()) {
                System.out.println("Warning: Some threads in the pool are still active.");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

// 清理资源
        executor.shutdownNow();

System.out.println("Execution finished.");
    }
}
```

这段代码创建了一个固定大小的线程池，然后提交了10个任务到线程池。每个任务都会被线程池中的一个线程来执行。

最后，我们关闭了线程池，并检查是否所有任务都已完成。如果还有活跃的线程，我们会发出警告信息。