一个简化版线程池设计

╰半夏微凉° 2023-01-01 01:45 146阅读 0赞

目前业界线程池的设计，普遍采用的都是生产者 - 消费者模式。

import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    
    public class MyThreadPool {
        //阻塞队列实现生产者-消费者模式
        BlockingQueue<Runnable> workQueue;
        //内部工作线程
        List<WorkThread> threads = new ArrayList<>();
    
        public MyThreadPool(int poolSize, int queueSize) {
            this.workQueue = new LinkedBlockingQueue<>(queueSize);
            //创建工作线程
            for(int idx = 0; idx < poolSize; idx++) {
                WorkThread work = new WorkThread();
                work.start();
                threads.add(work);
            }
        }
    
        //提交任务
        void execute(Runnable command) {
            try {
                workQueue.put(command);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    
        //工作线程负责消费任务，并执行任务
        class WorkThread extends Thread {
            public void run() {
                while(true) {
                    try {
                        Runnable task = workQueue.take();
                        task.run();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    
        public static void main(String[] args) {
            //创建线程池
            MyThreadPool pool = new MyThreadPool(6, 18);
            //提交任务
            pool.execute(()->{ System.out.println(Thread.currentThread() + " - demo"); });
        }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，146人围观）

还没有评论，来说两句吧...

相关阅读

相关线程池简洁版

每个人有自己的生活方式，每个人有自己对待感情的态度使用线程池的好处降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的销耗。提高响应速度。当任务到达时，任务可以...

骑猪看日落/ 2024年04月20日 07:21/ 0 赞/ 99 阅读

相关 C++实现一个线程池

一、为什么使用线程池大家都知道C++支持多线程开发，也就是支持多个任务并行运行，我们也知道线程的生命周期中包括创建、就绪、运行、阻塞、销毁等阶段，所以如果要执行的任务很

爱被打了一巴掌/ 2024年04月06日 10:13/ 0 赞/ 119 阅读

相关实现一个线程池 java

现在我有一个任务，希望异步执行，首先就考虑创建一个线程嘛第一版 package com.su.demo.test; import lombo

雨点打透心脏的1/2处/ 2024年04月03日 12:02/ 0 赞/ 123 阅读

相关 JAVA多线程并发（简化版）（一）

JAVA并发系列文章（一） \` -------------------- 文章目录 JAVA并发系列文章（一）前言一、JAVA线程如何实

╰+哭是因爲堅強的太久メ/ 2024年04月01日 14:56/ 0 赞/ 82 阅读

相关【多线程】实现一个线程池

![0ff875fd0e6c9fc94266771d065b483a.gif][] 1. 线程池的概念 1.1 什么是线程池？线程池也是一种线程的使用方式，前面

素颜马尾好姑娘i/ 2024年03月25日 10:29/ 0 赞/ 137 阅读

相关 Java版线程池实现

Java版线程池实现线程池调度技术原理： package test.threadpool; import java.util.\; import tes

矫情吗；*/ 2024年03月16日 20:32/ 0 赞/ 76 阅读

相关一个简化版线程池设计

目前业界线程池的设计，普遍采用的都是生产者 - 消费者模式。 import java.util.ArrayList; import java.util.Lis

╰半夏微凉°/ 2023年01月01日 01:45/ 0 赞/ 147 阅读

相关【网络编程】（四）BIO传统版、多线程版、线程池版对比

BIO：JDK1.4以前我们使用都是BIO 阻塞IO 阻塞到我们的读写方法 , 阻塞到线程来提供性能.对于线程的开销本来就是性能的浪费. 举例一［传统

缺乏、安全感/ 2022年06月06日 01:13/ 0 赞/ 279 阅读

相关 C++实现一个线程池

说明本线程池使用了互斥锁、条件变量、函数指针等常用工具。线程池的创建与执行 threadpool\_create创建线程池时，首先分配线程池数组和任务队列数组

淡淡的烟草味﹌/ 2022年02月16日 00:43/ 0 赞/ 281 阅读

相关我是一个线程池

线程池的自我介绍我是一个线程池（ThreadPoolExecutor），我的主要工作是管理在我这的多个线程（Thread），让他们能并发地执行多个任务的同时，又不会造成

╰半橙微兮°/ 2021年09月02日 03:12/ 0 赞/ 446 阅读