zoukankan      html  css  js  c++  java
  • canal 代码阅读

    涉及到有边界队列,无边界队列。poolSize、corePoolSize、maximumPoolSize 三者参数含义

    If there are more than corePoolSize but less than maximumPoolSize threads running, a new thread will be created only if the queue is full. By setting corePoolSize and maximumPoolSize the same, you create a fixed-size thread pool.

    he ThreadPoolExecutor has the following several key behaviors, and your problems can be explained by these behaviors.

    When tasks are submitted,

    1. If the thread pool has not reached the core size, it creates new threads.
    2. If the core size has been reached and there is no idle threads, it queues tasks.
    3. If the core size has been reached, there is no idle threads, and the queue becomes full, it creates new threads (until it reaches the max size).
    4. If the max size has been reached, there is no idle threads, and the queue becomes full, the rejection policy kicks in.

    In the first example, note that the SynchronousQueue has essentially size of 0. Therefore, the moment you reach the max size (3), the rejection policy kicks in (#4).

    问题就是使用SynchronousQueue,超过了maximumPoolSize还是能成功提交任务

    
    
    public static ThreadPoolExecutor newFixedThreadPool(int nThreads, long keepAliveTime) {
        return new ThreadPoolExecutor(nThreads,
            nThreads,
            keepAliveTime,
            TimeUnit.MILLISECONDS,
            new SynchronousQueue<>(),
            (r, exe) -> {
                if (!exe.isShutdown()) {
                    try {
                        exe.getQueue().put(r);
                    } catch (InterruptedException e) {
                        // ignore
                    }
                }
            });
    }
  • 相关阅读:
    pl2303 驱动
    tomcat 启动脚本
    Linux下Shell命令加减乘除计算
    定时删除文件夹"$1"下最后修改时间大于当前时间"$2"天的文件
    mysql 拼接字符
    jquery iframe父子框架中的元素访问方法
    在线工具
    js对数组对象的操作以及方法的使用
    HTML 设置字体
    10月1号 备忘录
  • 原文地址:https://www.cnblogs.com/studyNT/p/10780846.html
Copyright © 2011-2022 走看看