下面是一个简单的线程池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 = 1; i <= 10; i++) {
            executor.execute(new Task(i));
        }

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

    private static class Task implements Runnable {
        private int id;

        public Task(int id) {
            this.id = id;
        }

        @Override
        public void run() {
            System.out.println('Task ' + id + ' is running on thread ' + Thread.currentThread().getName());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println('Task ' + id + ' is complete');
        }
    }
}

以上代码使用了Java的线程池框架,通过创建一个固定数量的线程池来执行一系列任务。每个任务都是一个实现了Runnable接口的类,可以在run()方法中定义具体的任务逻辑。在这个例子中,每个任务都会休眠1秒钟,模拟一个耗时的操作。最后,当所有任务都执行完毕后,线程池会被关闭。

Java 线程池示例代码:创建固定线程池执行任务

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

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