请教下线程池提交线程池的写法 - V2EX
rqxiao
V2EX    Java

请教下线程池提交线程池的写法

  •  
  •   rqxiao Nov 29, 2022 3136 views
    This topic created in 1259 days ago, the information mentioned may be changed or developed.
     private static ThreadPoolExecutor getThreadPoolExecutor() { int corePoolSize=10; int maximumPoolSize=10; long keepAliveTime=1000L; BlockingQueue<Runnable> workQueue=new LinkedBlockingDeque<>(100); ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor( corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.MILLISECONDS, workQueue, new ThreadPoolExecutor.CallerRunPolicy() ); return threadPoolExecutor; } 

    如下种写法常用吗,判断 ActiveCount 来提交线程

     #1 int canCreateThreads = threadPool.getCorePoolSize()- threadPool.getActiveCount(); log.info(" 支持核心线程数 : {} 个, 已激活 {} 个线程, 还可创建线程数 : {} 个", threadPool.getCorePoolSize(), threadPool.getActiveCount(),canCreateThreads); if (canCreateThreads > 0) { executor .execute(new Runnable(){}) } 

    之前工作中一直使用这种简单的方式,有任务时,直接提交线程池,具体怎么执行根据线程池配置来。

    #2 executor.execute(new Runnable(){}) 
    17 replies    2022-11-29 18:51:01 +08:00
    shazi199
        1
    shazi199  
       Nov 29, 2022
    应该可以设置拒绝策略吧,没必要再去判断了
    ipwx
        3
    ipwx  
       Nov 29, 2022   1
    难道 canCreateThreads <= 0 就把任务扔了么。。。流控也不应该依赖 threadPool 的具体实现来做吧,这思路清奇。
    JadeLove
        4
    JadeLove  
       Nov 29, 2022
    用这个判断的话,那还需要 workQueue 干嘛。。。
    出于啥考虑要用这个方式啊,这个思路着实看不懂
    rqxiao
        5
    rqxiao  
    OP
       Nov 29, 2022
    额 。还有补充一点#1 里 runnable 的 run 方法 最后还会有一段这样的代码,每次执行完一个线程的逻辑之后,还给他 interrupt()一下,然后自抛自捕。


    ```
    finally {

    logger.debug("{} 队列消费,标志线程为中断", Thread.currentThread().getName());
    Thread.currentThread().interrupt();
    throw new InterruptedException(
    Thread.currentThread().getName() + ".run() interrupted : 执行完毕");
    }
    } catch (InterruptedException e) {
    if (e.getMessage().endsWith(SysConstants.FINISH_INTERRUPTED)) {
    logger.debug(e.getMessage());
    } else {
    logger.error(e.getMessage());
    }
    }
    ```
    rqxiao
        6
    rqxiao  
    OP
       Nov 29, 2022
    @rqxiao 这个代码也不是很明白
    chendy
        7
    chendy  
       Nov 29, 2022
    @rqxiao 看麻了,直接结束不就完事了么……
    rqxiao
        8
    rqxiao  
    OP
       Nov 29, 2022
    @urzz
    目前是这样的代码。但使用起来还没发生过
    else{
    logger.error(" 已达到本应用处理上限,请稍后再试");
    //TODO 发送消息通知
    }
    loveaeen
        9
    loveaeen  
       Nov 29, 2022
    使用线程池的优势就是其本身可以维护内部线程的中断与创建,不需要我们来管这东西。想拒绝线程可以设置 BlockQueue 和 rejectPolicy 来解决。
    如果你们非要想自己创建指定数量线程并且想在线程内随意中止,那么不如采用 AtomicInteger 之类的全手动增删。
    建议多看看 2 楼文档
    JadeLove
        10
    JadeLove  
       Nov 29, 2022
    @rqxiao 那还真是用线程池来实现流控啊,惊了个呆

    手动 interrupt 是没有什么意义的,因为线程池本身会去做这些事。。建议看看 2 楼的文档+1
    rqxiao
        11
    rqxiao  
    OP
       Nov 29, 2022
    总体的代码 ![ ]( https://imgur.com/a/oSc4eVD)
    wetalk
        12
    wetalk  
       Nov 29, 2022
    你的写法极少见,其次,getActiveCount()方法的注释有个单词,approximate ,近似的。

    [Returns the approximate number of threads that are actively executing tasks.]
    rqxiao
        13
    rqxiao  
    OP
       Nov 29, 2022
    Jooooooooo
        14
    Jooooooooo  
       Nov 29, 2022
    直接提交即可

    你应该把拒绝策略放到线程池里做, 线程池不就干这个的吗?
    X0ray
        15
    X0ray  
       Nov 29, 2022
    你这样还不如在外层加一个 Semaphore ,通过信号量的数量来控制提交和写日志
    theniupa
        16
    theniupa  
       Nov 29, 2022   1
    你还不如用一个 ArrayBlockingQueue 指定一个长度,在 RejectPolicy 里面拿到这个 work-queue,在满任务 put 阻塞一下..
    clickhouse
        17
    clickhouse  
       Nov 29, 2022
    workQueue 已经设置队列了,new ThreadPoolExecutor.CallerRunsPolicy() 也已经设置拒绝策略了,用线程池就是希望自动管理,所以你只管提交就可以了。如果你觉得实际与期望不符,那么你应该去修改新建线程池的参数。
    About     Help     Advertise     Blog     API     FAQ     Solana     1209 Online   Highest 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 52ms UTC 23:28 PVG 07:28 LAX 16:28 JFK 19:28
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86