以下是一个简单的线程池的示例源代码:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

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

        // 提交任务给线程池
        for (int i = 0; i < 10; i++) {
            Runnable worker = new WorkerThread("Task " + i);
            executor.execute(worker);
        }

        // 关闭线程池
        executor.shutdown();
        while (!executor.isTerminated()) {
        }
        System.out.println("Finished all tasks");
    }
}

class WorkerThread implements Runnable {
    private String taskName;

    public WorkerThread(String taskName) {
        this.taskName = taskName;
    }

    public void run() {
        System.out.println(Thread.currentThread().getName() + " Start. Task = " + taskName);
        processTask();
        System.out.println(Thread.currentThread().getName() + " End.");
    }

    private void processTask() {
        try {
            // 模拟任务处理时间
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

这个示例中,我们使用Executors.newFixedThreadPool()方法创建了一个线程池,大小为4。然后我们循环提交了10个任务给线程池,每个任务是一个实现了Runnable接口的WorkerThread对象。

WorkerThread对象的run()方法定义了任务的执行逻辑。在这个示例中,每个任务只是简单地打印一些信息,并通过processTask()方法模拟了一个耗时的任务处理过程。

最后,我们通过调用executor.shutdown()方法关闭线程池,并使用executor.isTerminated()方法等待所有任务完成

设计一个线程池且给出示例源代码

原文地址: https://www.cveoy.top/t/topic/iwzi 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录