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 关键字创...