Java并发编程：线程池与任务调度实例

原创客官°小女子只卖身不卖艺 2024-10-17 18:42 41阅读 0赞

在Java并发编程中，线程池和任务调度是非常重要的工具。下面我们将通过一个实例来详细理解这两种概念。

1. **线程池：**线程池是一种资源管理方式，它预先创建一定数量的线程，当有新的请求到来时，就从线程池中取出一个线程来执行任务，如果所有的线程都被占用，新的请求就会被暂时存储起来，等待线程释放。

2. **任务调度：**在Java中，线程池通常会内置某种形式的任务调度器。比如Apache的Commons Pool2库就提供了定时任务调度和线程回收功能。

以下是一个简单的线程池和任务调度的实例：

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

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

// 定义一个任务，这个任务将在2秒后执行一次
        Runnable task = () -> System.out.println("Task executed at " + new Date()));

// 创建一个定时任务调度器，周期为2秒
        ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(1);
        scheduledExecutor.scheduleAtFixedRate(task, 0, 2, TimeUnit.SECONDS));

// 当线程池的线程用完后，所有提交的任务将被阻塞，直到有线程可用
        executor.shutdown();
    }
}
```

在这个例子中，我们创建了一个固定大小的线程池，并定义了一个任务。然后通过定时任务调度器，使这个任务每2秒执行一次。

当所有线程都被任务占用时，新的提交任务将被阻塞，直到有线程可用。