使用Java编写的并发任务调度案例

原创客官°小女子只卖身不卖艺 2024-10-05 19:27 115阅读 0赞

在Java中，我们可以使用线程池（ThreadPoolExecutor）来实现并发任务的调度。下面是一个简单的例子：

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

public class ConcurrentTaskScheduler {

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

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskNumber = i;
            executor.submit(() -> {
                System.out.println("Task " + taskNumber + " is running in thread: " + Thread.currentThread().getName());
                try {
                    // 模拟耗时操作
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + taskNumber + " finished in thread: " + Thread.currentThread().getName());
            });
        }

// 关闭线程池
        executor.shutdown();

// 等待所有任务完成或线程池关闭超时
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(1000);  // 每秒检查一次
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All tasks finished or pool closed.");
    }
}
```

这个例子中，我们创建了一个固定大小的线程池来执行任务。每个提交的任务都会在自己的线程中运行，并打印出它们运行的详细信息。当所有任务完成或线程池关闭时，会打印出一条总结消息。