一个简化版线程池设计

╰半夏微凉° 2023-01-01 01:45 78阅读 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 条评论，78人围观）

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

相关阅读

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

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

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

相关如何手写一个线程池（附线程池的用法）

如何手写一个线程池（附线程池的用法）设计一个线程池设计代码 jdk线程池的分析解答思考题设计一个线程池

た入场券/ 2022年11月21日 04:05/ 0 赞/ 126 阅读

相关线程、线程池

创建线程的3种方法： package com.frank.threadPool.createThread; / @author 小石潭记

布满荆棘的人生/ 2022年10月22日 04:27/ 0 赞/ 276 阅读

相关一个线程池引发的悲剧

在对 Jetty 性能测试 AJP 静态页面发现，压力一上来 LR 端就出现 504 错误，查看 nginx 的 logs 发现大量请求 upstream timeout

迷南。/ 2022年09月30日 04:55/ 0 赞/ 141 阅读

相关手写线程池 - C++版

在[《手写线程池 - C语言版》][- C] 对这些代码做从 C 到 C++ 的迁移主要用到了 C++ 三大特性中的封装，因此难度不大，对应 C++ 初学者来说有助于提高编码

╰+攻爆jí腚メ/ 2022年09月13日 00:28/ 0 赞/ 122 阅读

相关手写线程池 - C语言版

1. 线程池原理我们使用线程的时候就去创建一个线程，这样实现起来非常简便，但是就会有一个问题：如果并发的线程数量很多，并且每个线程都是执行一个时间很短的任务就结束了，这

忘是亡心i/ 2022年09月12日 13:55/ 0 赞/ 125 阅读

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

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

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

相关一个线程池处理线程死亡造成的血案

真不知道大家有没有遇到过这种问题： 1.任务处理一半，线程挂了怎么办？ 2.线程池有没有补齐线程的功能？这里举一个小demo，用来处理线程死掉，重启线程处理任务。

心已赠人/ 2022年05月16日 13:22/ 0 赞/ 153 阅读

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

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

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

相关我是一个线程池

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

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