以下是使用 Java 代码实现 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);

        // 提交10个任务给线程池执行
        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 threads');
    }
}

class WorkerThread implements Runnable {
    private String taskName;

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

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + ' start ' + taskName);

        // 模拟任务执行
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println(Thread.currentThread().getName() + ' end ' + taskName);
    }
}

上述代码使用 Java 自带的 Executor 框架创建了一个固定大小的线程池,向线程池提交了 10 个任务。每个任务都是一个 Runnable 对象,其中的 run 方法模拟了任务的执行过程。最后,线程池被关闭并等待所有任务执行完毕。在任务执行的过程中,可以看到线程池会自动分配线程来执行任务。

Java 线程池实现示例:使用 Executors 框架

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

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