1、生产者基类（父类）class BaseProducer(object): ''' 生产者 ''' def __init__(self,name): ''' 初始化生产对象 :param name:生产名...

题意：就是多个窗口服务，每次来的人选择一个等待时间最短的窗口。问所有人的平均等待时间

【1】Executors.newFixedThreadPool(n)：创建一个定长的线程池，可控制线程最大并发数，超出的线程会在队列中等待。创建的线程池 corePoolSize 和 maximumPoolSize 值是相等的，使用的是 LinkedBlockingQueue 阻塞队列。执行...

sar命令用于全面地获取系统的CPU、运行队列、磁盘 I/O、分页（交换区）、内存、 CPU中断和网络等性能数据。

队列（Queue）简称队，也是一种操作受限的线性表，只允许在表的一端进行插入，而在表的另一端进行删除。向队列中插入元素称为入队或进队；删除元素称为出队或离队。这和我们日常生活中的排队是一致的，最早排队的也是最早离队的，其...

handleDelivery是回调方法，如果队列中有消息就会执行这个方法，参数中的body就是消息内容。channel.basicConsume 方法中第二个参数为boolean 类型，意思是消息的ack 需要自动（true）还是手动(false)。...

话不多少，直接上代码1. 手写队列package com.jiafupeng.test;/** * @author jiafupeng * @desc * @create 2021/4/10 15:59 * @update 2021/4/10 15:59 **/public class MyQueu...

1. FIFO Scheduler 2. Capacity Scheduler 3. Fair Scheduler

LinkedTransferQueue 是一种 TransferQueue，SynchronousQueue 是一种 BlockingQueue。

在当前P(处理器)上创建G(groutine)后 , 会把G放入P的本地队列或者全局队列 , 本地队列限制256个 , 满了就放全局队列