sleep等待, 单位为毫秒, 已捕捉并处理InterruptedException. @param durationMillis durationMillis

提交任务 @param command command

Adds the given value. @param x the value to add

@see FixedThreadPoolBuilder

获取 / 释放悲观读锁 @return o

Pool大小，默认为1，即singleThreadPool

与ThreadFactory互斥, 优先使用ThreadFactory

Returns the current sum. The returned value is <em>NOT</em> an atomic snapshot; invocation in the absence of concurrent updates returns an accurate r

符合条件则打印线程栈

Returns the String representation of the {@link #sum}. @return the String representation of the {@link #sum}

优先使用threadFactory，否则如果threadNamePrefix不为空则使用自建ThreadFactory，否则使用defaultThreadFactory

判断是否有log.

写 @param key k @param v v @return v

释放资源 @param resource re @throws InterruptedException e

将此appender添加到logger中.

一次性申请所有资源 @param from 转入账户 @param to 转出账户 @return boolean

@see CachedThreadPoolBuilder

CASes the busy field from 0 to 1 to acquire lock.

将key的hashCode的低16位于高16位进行异或运算 re hash @param h hashCode @return int

创建ThreadFactory，使得创建的线程有自己的名字而不是默认的"pool-x-thread-y" 使用了Guava的工具类 @see ThreadFactoryBuilder#build()

cancel

CASes the base field.

优化的创建函数，如果为0或100时，返回更直接的采样器

Computes the function of current and new value. Subclasses should open-code this update function for most uses, but the virtualized form is needed wit

归还资源 @param from 转入账户 @param to 转出账户

WaitAndNotifyAllocator 为单例 @return WaitAndNotifyAllocator

Returns a sun.misc.Unsafe. Suitable for use in a 3rd party package. Replace with a simple call to Unsafe.getUnsafe when integrating into a jdk. @ret

run

顺序执行 @param list list @return sum

获取 / 释放写锁

占用任务

同步转账 @param target 目标账户 @param amt 转账数量

只有当目前 count 的值和期望值 expect 相等时，才会将 count 更新为 newValue。 @param expect 期望值 @param newValue 更新值 @return 旧值

count值+1 @return @throws InterruptedException

非线程安全计数器

返回CountDownLatch, 每条线程减1，减到0时正在latch.wait()的进程继续进行

一个用来定制RateLimiter的方法，默认一开始就桶里就装满token。 @param permitsPerSecond 每秒允许的请求数，可看成QPS。 @param maxBurstSeconds 可看成桶的容量，Guava中最大的突发流量缓冲时间，默认是1s, permitsPerSec

打印全部的stack，重新实现threadInfo的toString()函数，因为默认最多只打印8层的stack. 同时，不再打印lockedMonitors和lockedSynchronizers @param thread t @param stackTrace s @param sb sb

FutureTask由线程池执行

FutureTask由线程处理

利用对象池的对象，调用 func @param func func @return R @throws InterruptedException ex

利用FutureTask实现烧水泡茶

获取count值 @return @throws InterruptedException

获取资源 阻塞等待 @return resource @throws InterruptedException e

返回之前append的所有log.

返回之前append的第一个log.

返回之前append的最后一个log.

按照ExecutorService JavaDoc示例代码编写的Graceful Shutdown方法. 先使用shutdown, 停止接收新任务并尝试完成所有已存在任务. 如果1/2超时时间后, 则调用shutdownNow,取消在workQueue中Pending的任务,并中断所有阻塞函数.

Equivalent to {@code add(1)}.

Sets base and all cells to the given value.

打印 @param message mes @throws InterruptedException e

释放任务

Handles cases of updates involving initialization, resizing, creating new Cells, and/or contention. See above for explanation. This method suffers the

run

使用CAS 实现线程安全计数器

与threadFactory互斥, 优先使用ThreadFactory 默认为NULL，不进行设置，使用JDK的默认值.

打印ThreadDump的最小时间间隔，单位为秒，默认为0不限制 @param leastIntervalSeconds s

停止打印 @throws InterruptedException e

初始化容量大小 转换为2的幂次方 @param c size @return int

强行打印ThreadDump，使用最轻量的采集方式，不打印锁信息 @param reasonMsg msg