java线程池运用场景最多的并发框架,几乎所有需要异步或者并发执行的都需要线程池,好处 1) 降低资源消耗 2) 提高响应速度 3) 提高线程的可管理性(统一分配调度) 线程池的实现原理: 1) 线程池判断核心线程是否都在工作,如果不是,则创建一个新的工作线程来执行任务,否则进入下一个 2) 线程池判断工作队列是否已经满,如果工作队列没有满,就将新提交的任务存储在工作队列中,如果工作队列满了,就进入下一个流程 3) 线程池判断线程是否都处于工作状态.如果没有,就创建一个新的工作线程来执行任务.如果已经满了,则交给饱和策略来处理这个任务. runnableTa...

Semaphore(信号量)使用来控制同时访问特定资源的线程数量.它通过协调各个线程,以保证合理的使用公共资源.可以把它比作是控制流量的红绿灯. public class SemaphoreTest { private static final int THREAD_COUNT = 30; private static ExecutorService threadPool = Executors.newFixedThreadPool(THREAD_COUNT); private Semaphore s = new Semaphore(10); public static void main...

(1) CountDownLatch的计数器只能使用一次,CyclicBarrier的计数器可以使用reset()进行重置,能处理更为复杂的业务场景(2) CyclicBarrier还有其他方法,比如getNumberWaiting方法可以获得CyclicBarrier阻塞的线程数量,isBroken()方法用来了解阻塞的线程是否被中断.(3) CyclicBarrier还有回调方法barrierAction()

1 重入锁定义 ReentrantLock虽然没能像synchronized关键字一样支持隐式的重进入,但是在调用lock()方法时,已经获取到锁的线程,能够再次调用lock()方法获取锁而不被阻塞. 2 读写锁定义 读写锁维护了一对锁,一个读锁,一个写锁.通过分离读锁和写锁,使得并发性相比一般的排他锁有了很大的提升. 除了保证读写操作对读操作的可见性和并发性提升之外,在读多于写的情况下,读写锁能够提供比排他锁更好的并发性和吞吐量. 3 读写锁的实现分析 读写的状态设计,写锁的释放和获取,读锁的释放以及获取,以及锁降级. (1)读写状态的设计 读写锁同样依...

1 队列同步器(AQS) 用来构建锁或者其他同步组件的基础框架,使用了一个int成员表示同步状态,通过内置的FIFO队列来完成资源获取线程的排队工作. 同步器的主要使用方式是继承,子类通过继承同步器并实现它的抽象方法来管理同步状态,在抽象方法的实现过程中免不了要对同步状态进行更改. 同步器自身没有实现任何同步接口,它仅仅是定义了若干同步状态获取和释放的方法来供自定义同步组件来使用,同步器既可以支持独占式获取同步状态,也可以共享式的获取同步状态. 2 队列同步器的实现分析 (1) 同步队列 同步器依赖内部的同步队列(FIFO双向队列)来完成同步状态的管理,当...

volatile的定义和实现原理1 cpu术语定义 内存屏障: 是一组处理器指令,用于实现对内存操作的顺序限制 缓冲行: cpu高速缓存中可以分配的最小存储单位.处理器填写缓存行时会加载整个缓存行,现代cpu需要执行几百次cpu指令 2 volatile编译之后会产生Lock指令 1)将当前处理器缓存行的数据写回到系统内存 2)这个写回内存的操作会使其他cpu里缓存了该内存地址的数据无效为了提高处理速速,处理器不直接和内存进行通信,而是先将内存的数据读到内部缓存后再进行操作,但操作完之后不知道何时会写回内存.如果对volatile的变量进行写操作,jvm就会像处理器发送...

核心微服务的开发模式1 服务粒度2 通信协议3 接口设计4 服务的配置管理5 服务之间的事件处理 微服务的路由模式1 服务发现 服务发现从客户端抽象出服务的物理位置.可以添加新的微服务实例来进行扩大,并且可以透明的从服务中删除不健康的服务实例. 2 服务路由 服务路由为微服务客户端提供了单一的逻辑URL来进行通信,并作为授权,验证和检查等内容的策略实施点. @RestController是一个类级别注解,它告诉java类将用于基于rest的服务.此注解自动处理以json或者xml方式传毒到服务中的数据的序列化.与传统的Spring @Controller注解不同,@Rest...

ZAB协议ZAB协议是为分布式协调服务zookeeper专门设计的一种支持崩溃恢复的原子广播协议。具体的,Zookeeper使用一个单一的主进程来接收并处理客户端的所有事务请求,并采用zab的原子广播协议。 针对客户端的事务请求,leader服务器会为其产生对应事务的proposal,将其发送给集群中其余所有的机器,然后再分别收集各自的选票,最后进行事务提交. 在zab二段提交中,意味着我们可以在过半的follower服务器已经反馈过ack之后就开始提交proposal了,而不需要等待集群中所有的follower都反馈响应. 在整个消息广播过程中,Leader服务器会为每个事...

zookeeper简介zookeeper为分布式应用提供了高效且可靠的分布式协调服务,提供了统一命名服务,配置管理和分布式锁等 分布式的基础服务.Zookeeper并没有直接采用paxos算法,而是采用了ZAB的一致性协议. zookeeper是什么呢? Zookeeper是一个典型的分布式数据一致性的解决方案,分布式程序可以基于它事项诸如数据发布订阅,命名服务,负载均衡,分布式协调通知,集群管理,master选举,分布式锁和分布式队列等.zookeeper的设计目标 1 简单的数据模型 zookeeper使得分布式能够通过共享的,树形结构的名字来进行相互协...