分析 每个消息一个线程。message可以理解为命令，请求。为每一个请求新分配一个线程，由这个线程来执行处理。 Thread-Per-Message模式中，请求的委托端和请求的执行端是不同的线程，请求的委托端会告诉请求的执行端线程：这项工作就交给你了 编码 public class MessageHandler { private final static Random RANDOM = new Random(System.currentTimeMillis()); public void request(Message message){ ...

分析 Two-Phase Termination Pattern,指的就是当希望结束一个线程的时候，送出一个终止请求，但是不会马上停止，做一些刷新工作。进入“终止处理中”，在该状态下，不会进行该线程日常工作任务的操作，而是进行一些终止操作。 这个方式所考虑的因素如下： 1，必须要考虑到使得该线程能够安全的结束，Thread中的stop会有问题的，因为它会不管线程执行到哪里，都会马上停止，不能保证安全的结束。 2，一定能够进行正常的终止处理，在java中，这点可以使用finally来实现 3，能够高响应的终止，收到终止后，当线程在wait或者sleep或者join的...

分析 Master-Worker模式是常用的并行设计模式。核心思想是，系统由两个角色组成，Master和Worker Master负责接收和分配任务 Worker负责处理子任务 任务处理过程中，Master还负责监督任务进展和Worker的健康状态；Master将接收Client提交的任务，并将任务的进展汇总反馈给Client。 基本框架 主要需要设计一个队列，开启多个线程 然后任务就按照队列的先后顺序放在上面 多个线程也按照先后顺序执行 public class Channel { private final static int MAX...

这里写目录标题 一、分析 二、实现一个ActiveObject 设计模式 ActiveObject 核心思想 指令的接收与分发 结果的封装和返回 一、分析 Active是主动的意思，因此ActiveObject就是主动对象的意思。所谓主动一般指有自己特有的线程，举例来说，java.lang.Thread类的实例就是一种主动对象。 不过，在Active Object模式中出厂的主动对象可不仅仅有自己特有的线程，它同时还具备可以从外部接收和处理异步消息并根据需要返回处理结果的特征。 Active Object模式中的主动对象会通过自己特有的...

目录 一、CAS机制 二、举例 三、CAS的缺点 四、利用CAS实现TryLock 五、ABA问题 基本问题 解决方式--AtomicStampedReference 一、CAS机制 CAS机制当中使用了3个基本操作数：内存地址V，旧的预期值A，要修改的新值B。 更新一个变量的时候，只有当变量的预期值A和内存地址V当中的实际值相同时，才会将内存地址V对应的值修改为B。 从思想上来说，Synchronized属于悲观锁，悲观地认为程序中的并发情况严重，所以严防死守。 CAS属于乐观锁，乐观地认为程序中的并发情况不那么严重，所以让线...

这里写目录标题 引出 源码阅读 1. 定义的变量 2. layzSet方法: 3. set方法 4. 增加和减少 CAS 引出 高并发的情况下，i++无法保证原子性，往往会出现问题，所以引入AtomicInteger类。 public class TestAtomicInteger { private static final int THREADS_COUNT = 2; public static int count = 0; public static volatile int count...

分析 在高并发条件下，如果都需要对flag进行修改，就会破坏其原子性 观察下面代码 public class AtomicBooleanTest { private static volatile Boolean flag = true; public static void main(String[] args) { for (int i = 0; i < 10; i++) { new Thread(() -> { if (flag) { ...

AtomicReference 提供了引用变量的读写原子性操作。 提供了如下的方法： compareAndSet(V expect, V update) getAndSet(V newValue) lazySet(V newValue) set(V newValue) get() 举例 public class AtomicReferenceTest { private static AtomicReference<Simple> reference = new AtomicReference<>(n...

引出 由于原子性的类型是后期引出的，但是想让原来已经写好的属性也具有原子性，就可以利用这个类 AtomicXXXFieldUpdater主要包括以下几个：AtomicIntegerFieldUpdater，AtomicLongFieldUpdater，AtomicReferenceFieldUpdater。 要求 字段必须是volatile类型的，在线程之间共享变量时保证立即可见 字段的描述类型（修饰符public/protected/default/private）是与调用者与操作对象字段的关系一致。也就是说调用者能够直接操作对象字段，那么就可以反射进行原子操作。 对于...

比较几种Counter的自增操作时间 编写一个没有做任何处理的自增 static class StupidCounter implements Counter{ private long counter = 0; @Override public void increment() { counter++; } @Override public long getCounter() { return counter; } } 编写一个加内置锁的自增 static class SyncCounte...

目录 简介 获取Unsafe 主要功能 CAS相关 偏移量相关 类加载 普通读写 类加载 内存屏障 线程调度 简介 Unsafe类是在sun.misc包下，不属于Java标准。但是很多Java的基础类库，包括一些被广泛使用的高性能开发库都是基于Unsafe类开发的，比如Netty、Cassandra、Hadoop、Kafka等。Unsafe类在提升Java运行效率，增强Java语言底层操作能力方面起了很大的作用。 Java和C++语言的一个重要区别就是Java中我们无法直接操作一块内存区域，不能像C++中那样可...

目录 一、引入 二、分析 三、使用场景一 四、使用场景二 五、API使用 六、给离散的平行任务增加逻辑层次关系 一、引入 countDownLatch这个类使一个线程等待其他线程各自执行完毕后再执行。 是通过一个计数器来实现的，计数器的初始值是线程的数量或者任务的数量。 每当一个线程执行完毕后，计数器的值就-1，当计数器的值为0时，表示所有线程都执行完毕，然后在闭锁上等待的线程就可以恢复工作了。 CountDownLatch的方便之处在于，你可以在一个线程中使用，也可以在多个线程上使用，一切只依据状态值，这样便不会受限于任何的场景。 ...

引出 栅栏类似于闭锁，它能阻塞一组线程直到某个事件的发生。栅栏与闭锁的关键区别在于，所有的线程必须同时到达栅栏位置，才能继续执行。闭锁用于等待事件，而栅栏用于等待其他线程。 CyclicBarrier可以使一定数量的线程反复地在栅栏位置处汇集。当线程到达栅栏位置时将调用await方法，这个方法将阻塞直到所有线程都到达栅栏位置。 如果所有线程都到达栅栏位置，那么栅栏将打开，此时所有的线程都将被释放，而栅栏将被重置以便下次使用。 举个例子，就像生活中我们会约朋友们到某个餐厅一起吃饭，有些朋友可能会早到，有些朋友可能会晚到，但是这个餐厅规定必须等到所有人到齐之后才会让我们进去。这里的朋友们就是...

简介 用于两个工作线程之间交换数据的封装工具类 简单说就是一个线程在完成一定的事务后想与另一个线程交换数据，则第一个先拿出数据的线程会一直等待第二个线程，直到第二个线程拿着数据到来时才能彼此交换对应数据 Exchanger<V> 泛型类型，其中 V 表示可交换的数据类型 简单的应用 public class ExchangerTest { public static void main(String[] args) { final Exchanger<String> exchanger = new Exchanger&lt...