描述: AbortPolicy线程拒绝策略 如果线程池已满，退出申请并打印Thread Dump(会有一定的最少间隔，默认为10分钟） @author zed

@author zed AbortPolicyWithReportTest

通过锁类对象方式 同样能解决并发问题 但是会导致操作串行 性能极差故不推荐

破坏占用且等待条件 加入分配类，只有在同时拿到两个锁的时候才可以执行后续操作

采样率为100时，总是返回true

java实现原子操作 补充CAS 实现原子操作的三大问题 1、ABA问题 解决方式 加上版本号1A、2B、3A java 1.5 后提供AtomicStampedReference 检查当前引用是否符合预期引用，并检查当前标志是否等于预期标志 2、循环时间长开销大 3、只能保证一个共享变量的原子操作

描述: 阻塞队列 @author zed @since 2019-06-13 5:15 PM

描述: 读写锁实现缓存 ReentrantReadWriteLock 只支持锁的降级 不支持锁升级 并且只有写锁可以创建条件变量 读写锁允许多个线程同时读共享变量，当一个线程在写共享变量的时候，是不允许其他线程执行写操作和读操作。 @author zed @since 2019-06-17 5

创建CachedThreadPool, maxSize建议设置 1. 任务提交时, 如果线程数还没达到minSize即创建新线程并绑定任务(即minSize次提交后线程总数必达到minSize, 不会重用之前的线程) minSize默认为0, 可设置保证有基本的线程处理请求不被回收. 2. 第

Padded variant of AtomicLong supporting only raw accesses plus CAS. The value field is placed between pads, hoping that the JVM doesn't reorder them.

描述: CompletableFutureExample Java 8 异步编程可描述串行关系、AND汇聚关系和OR汇聚关系以及异常处理 @author zed @since 2019-07-03 1:57 PM

@author zed

描述: C map Test @author zed @since 2019-06-04 2:30 PM

@author zed 并发常用工具类

描述: 条件队列 通过ReentrantLock 实现打印和停止打印的条件队列，每次容量为5 @author zed @since 2019-07-01 10:59 AM

描述: 控制台输出时间任务取消 通过interrupt() 注意抛出InterruptedException异常的地方需要重置下打断标识 适用场景:当后台任务需要取消时 @author zed @since 2019-06-30 3:18 PM

@author zed 上下文切换测试类 1、结论 循环数量在百万级别时 并发处理速度才会领先，说明上下文切换的存在以及线程创建的成本 2、使用Lmbench3 测量上下文切换时长，使用vmstat 查看测量上下文切换次数上下文速度 1000次/s 3、减少上下文切换 1）无锁并发编程-》多线程锁

https://github.com/apache/tomcat/blob/trunk/java/org/apache/tomcat/util/threads/TaskQueue.java

描述: 基于CountDownLatch实现应用初始化 适用场景:多个重要资源的初始化 @author zed @since 2019-07-01 11:17 AM

描述汇聚Or关系 thenApply

描述: CountDownLatchEx 中文意思 倒计时 主要用来解决一个线程等待多个线程的场景 @author zed @since 2019-06-18 10:20 AM

描述: CyclicBarrierEx 中文意思 篱栅 是一组线程之间互相等待 @author zed @since 2019-06-18 10:27 AM

分别加锁方式 支持并行 锁粒度变细性能提升 但是 会导致严重问题： 死锁！！

@author zed 死锁测试 避免死锁常用方法 1、避免一个线程同时获取多个锁 2、避免一个线程在锁内同时占用多个资源，尽量保证每个锁只占用一个资源 3、尝试使用定时锁，使用lock.tryLock(timeOut) 来替代使用内部锁机制 4、对于数据库锁，加锁和解锁必须在一个数据库连接里，否则

处理异常 此例为发生异常默认为0

描述: 交换者 用于两个线程间的数据交换 @author zed @since 2019-07-03 5:39 PM

描述: CompletionService BlockingQueue+Executor 批量执行异步任务 并且可以支持Forking Cluster模式即并行查询多个服务其中一个返回则结束 @author zed @since 2019-07-03 10:07 AM

描述: 构造函数的错误重排导致线程可能看到 final 变量的值会变 FinalExample @link http://www.cs.umd.edu/~pugh/java/memoryModel/jsr-133-faq.html @author zed @since 2019-06-13 1:3

描述: 处理锁顺序问题 （防止死锁）@link com.example.concurrency.features.synchronizedcase.SynchronizedResolveDeadLock.SortExeAccount 适用场景：处理多个锁时 @author zed @since 20

创建FixedThreadPool.建议必须设置queueSize保证有界。 1. 任务提交时, 如果线程数还没达到poolSize即创建新线程并绑定任务(即poolSize次提交后线程总数必达到poolSize，不会重用之前的线程) poolSize默认为1，即singleThreadPool

描述: FutureTaskEx @author zed @since 2019-06-18 4:52 PM

在List中保存日志的Appender, 用于测试Logback的日志输出. 在测试开始前, 使用任意一种addToLogger()方法将此appender添加到需要侦听的logger中.

移植 http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/jsr166e/LongAdder.java Revision.1.17 One or more variables that together maintain an initi

Semaphore 实现互斥

描述: 简化的线程池，仅用来说明工作原理 @author zed @since 2019-06-18 3:10 PM

采样率为0时，总是返回false

实现限流器 @param <T> @param <R>

描述: 平行分治 fork/join @author zed @since 2019-07-01 11:59 AM

分治执行

乐观读升级官方示例

描述: 生产消费 @author zed @since 2019-07-01 2:12 PM

@author zed From Tomcat 8.5.6, 传统的FixedThreadPool有Queue但线程数量不变，而CachedThreadPool线程数可变但没有Queue Tomcat的线程池，通过控制TaskQueue，线程数，但线程数到达最大时会进入Queue中. 代码从To

从Tomcat移植过来的可扩展可用Queue缓存任务的ThreadPool @see 20.0

@author zed RateLimiterUtil

资源1

资源2

资源3

描述: 对象资源池 适用场景:当要创建某些有限资源的池时使用 @author zed @since 2019-07-01 3:01 PM

通过传入锁的方式 但是必须保持lock对象跟SafeAccount 一对一绑定 并且真实场景中创建账户对象的地方可能是分布式，所以会很复杂极不推荐！

利用Synchronized 实现原子操作

保证不会有Exception抛出到线程池的Runnable包裹类，防止用户没有捕捉异常导致中断了线程池中的线程, 使得SchedulerService无法执行. 在无法控制第三方包的Runnalbe实现时，使用本类进行包裹.

@author zed 采样器 移植 Twitter Common, 优化使用ThreadLocalRandom https://github.com/twitter/commons/blob/master/src/java/com/twitter/common/util/Sampler.jav

创建ScheduledPool

描述: Semaphore example acquire() 为原子操作 保证只有一个线程能将count减为0 则其他线程阻塞等待，release()+1后得以执行 @author zed @since 2019-06-17 3:50 PM

描述串行关系 thenApply

描述: 通过锁和volatile 实现的线程共享方案 适用场景：特定条件下有效阻止并行执行 @author zed @since 2019-07-02 3:33 PM

描述: SimulatedCompareAndSwap 模拟cas操作 @author zed @since 2019-06-18 2:09 PM

描述: 双重检查锁实现单例 @author zed

根据账户id 排序保证获取锁顺序避免出现竞争 成本相对上面较低

描述: StampedLockEx 写锁和悲观锁 跟ReentrantReadWriteLock 类似，非可重入锁，并且不支持条件变量 ReadWriteLock 支持多个线程同时读，但是当多个线个线程同时读的时候， 所有的写操作会被阻塞；而 StampedLock 提供的乐观读（无锁），是允许一个

@author zed

移植 http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/jsr166e/Striped64.java Revision 1.10 A package-local class holding common representation a

描述: 保护有关联关系的多个资源 银行转帐问题 @author zed @since 2019-06-13 1:13 PM

描述: Synchronized 实现原理 基于操作系统Mutex Lock (互斥锁)实现，所以每次获取和释放都会由用户态和内核态的切换成本高，jdk1.5之前性能差 JVM通过ACC_SYNCHRONIZED 标识一个方法是否为同步方法,而代码块则通过monitorenter和monitorex

描述: 保护没有关联关系的多个资源 银行账户密码和余额没有关联关系 @author zed @since 2019-06-13 2:12 PM

描述: 解决死锁问题 @author zed @since 2019-06-13 3:35 PM

直接对转账方法做同步方式 锁对象为this 而target对象资源不受保护

洗水壶、烧开水、泡茶

洗茶壶、洗茶杯、拿茶叶

描述: 聚合任务 CyclicBarrier(int parties, Runnable barrierAction) barrierAction为到达屏障后优先执行的任务 适用场景:当需要确定一组正在运行的任务是否已完成时 @author zed @since 2019-06-30 3:3

描述: 由程序触发的ThreadDump，打印到日志中 因为ThreadDump本身会造成JVM停顿，所以加上了开关和最少间隔时间的选项(默认不限制) 因为ThreadInfo的toString()最多只会打印8层的StackTrace，所以加上了最大打印层数的选项(默认为8) @author z

描述: ThreadDumpHelper Test @author zed @since 2019-06-03 11:26 AM

@author zed ThreadPool创建的工具类. 对比JDK Executors中的newFixedThreadPool(), newCachedThreadPool(),newScheduledThreadPool, 提供更多有用的配置项. 另包含了移植自Tomcat的Queuabl

线程池工具集 1. 优雅关闭线程池的(via guava) 2. 创建可自定义线程名的ThreadFactory(via guava) 3. 防止第三方Runnable未捕捉异常导致线程跑飞 @author calvin

描述: 线程状态一览 @author zed

描述: ThreadUtil 1. 处理了InterruptedException的sleep 2. 正确的InterruptedException处理方法 @author zed

描述: TimeIntervalLimiter @author zed

线程不安全

描述: visibility 可见性问题 @author zed @since 2019-06-13 9:05 AM