Executor线程池执行器,Executors类提供工厂方法实现,返回的都是ExecutorService接口的之类,内部是ThreadPoolExecutor通过构造方法创建线程池;
ThreadPoolExecutor有核心线程数(corePoolSize)和最大线程数(maximumPoolSize),如果运行的线程数少于核心线程数,则创建新线程;排队三种策略:直接提交(SynchronousQueue 直接创建新线程)、无界队列(LinkedBlockingQueue 只创建核心线程数的线程,其他的都排队)和有界队列(ArrayBlockingQueue 先创建核心线程数,再放到队列存储一部分,再创建小于最大线程数的线程,大于最大值的线程执行拒绝策略);默认拒绝策略为抛出异常;
ScheduledThreadPoolExecutor继承自ThreadPoolExector,排队策略采用DelayedWorkQueue;scheduleAtFixedRate方法以固定周期执行,不管上次是否执行完毕;scheduleWithFixedDelay以固定延迟时间执行,需要等上次任务执行完成后再按延迟时间执行;
Callable接口与Runnable不同的是可返回Future对象;Future是异步获取返回值,返回值存放在一个Object属性,通过泛型转换,获取值前会调用wait()休眠,等返回值时再次唤醒,因此此类会导致阻塞;FutureTask是其中一个常用的实现类;
数据同步,synchronized有两个功能,线程互斥和范围内数据其它线程可见,volitile也是保证变量在多线程可见;atomic通过CAS方式提供原子性的自增方法,也是线程安全的;
Lock 替代了 synchronized 方法和语句的使用,有lock、tryLock和unlock方法,作用是线程互斥,配合Condition 对象进行阻塞唤醒等操作;
ReadWriteLock读写锁,与InnoDB的共享锁和独占锁类似,可以运行多个线程读和一个线程写,有写操作时读操作不能进行;
Condition 替代了 Object的wait、notify 和 notifyAll,方法包括await、signal、signalAll,用于阻塞与唤醒;Condition 可以通过lock.newCondition()方法获得,假设只有一个Condition,缓存队列中已经存满,这个Lock不知道唤醒的是读线程还是写线程了,如果唤醒的是读线程,皆大欢喜,如果唤醒的是写线程,那么线程刚被唤醒,又被阻塞了,这时又去唤醒,这样就浪费了很多时间;
同步器有四种:Semaphore(信号量)用来控制同时访问特定资源的线程数量;CountDownLatch主要有await和countDown两个方法,初始化计数器后调用await使线程进入阻塞状态,直到countDown为0后自动唤醒;CyclicBarrier即线程都执行到一个点后相互等待;Exchanger 允许两个线程在 collection 点交换对象;
AbstractQueuedSynchronizer是用于构建锁或者其他相关同步装置的基础框架,通过acquire方法独占对象,release方法释放独占对象;
Java多线程
最后编辑于 :
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
推荐阅读更多精彩内容
- Java-Review-Note——4.多线程 标签: JavaStudy PS:本来是分开三篇的,后来想想还是整...
- 第三章 Java内存模型 3.1 Java内存模型的基础 通信在共享内存的模型里,通过写-读内存中的公共状态进行隐...
- 一、多线程 说明下线程的状态 java中的线程一共有 5 种状态。 NEW:这种情况指的是,通过 New 关键字创...