美文网首页
多线程,以及在定时任务模块中的应用

多线程,以及在定时任务模块中的应用

作者: aker0215 | 来源:发表于2019-08-02 09:23 被阅读0次

线程和进程

基本线程类,怎样开启一个线程,线程状态以及系统调度

wait, notify 必须在synchronized块中调用

Thread类,Runnable接口,Callable接口

  • 继承Thread类,重写该类的run()方法。

  • 实现Runnable接口,并重写该接口的run()方法

  • 使用Callable和Future接口创建线程。

Thread和Runnable的实现区别

获取线程中的异常

异常不能跨线程传播会main线程,所以必须在本地处理所有在任务内部产生的异常

UncaughtExceptionHandler

线程的优先级,让步,后台线程,join()

线程间数据的共享以及线程安全,共享受限资源

volatile,Synchronized,Lock,ReentrantLock(下数那边可以用这个来避免重复执行,允许你尝试获取但最终未获取锁,这样如果其他人已经获取了这个锁,那你就可以设定等待的超时时间,也可以决定离开去执行其它的事情)

如果一个域完全有synchronized方法或语句来保护,那就不必将其设置为是volatile的

原子类,AtomicInteger,AtomicLong,AtomicReference

其底层就是volatile和CAS 共同作用的结果:

  • 首先使用了volatile 保证了内存可见性。

  • 然后使用了CAS(compare-and-swap)算法 保证了原子性。

​ 其中CAS算法的原理就是里面包含三个值:内存值A 预估值V 更新值 B 当且仅当 V == A 时,V = B; 否则,不会执行任何操作。

BlockingQueue

ConcurrentHashMap

线程的本地存储:ThreadLocal类

线程池

ThreadPoolExecutor

无需显式的管理线程的生命周期

  • 重复利用已存在并空闲的线程,从而减少线程对象的创建和线程消亡的开销

  • 有效控制最大并发线程数,提高系统资源使用率,同时避免过多资源竞争

  • 提供定时、定期、单线程、并发数控制等功能

  • Future,Callable提供了更好的异步执行控制

Future.get(); Future.isDone();Future,cancel()…

创建线程池主要有三个静态方法供我们使用,由Executors来进行创建相应的线程池:

  • newSingleThreadExecutor返回以个包含单线程的Executor,将多个任务交给此Exector时,这个线程处理完一个任务后接着处理下一个任务,若该线程出现异常,将会有一个新的线程来替代。

  • newFixedThreadPool返回一个包含指定数目线程的线程池,如果任务数量多于线程数量,那么没有执行的任务必须等待,直到有任务完成为止。

  • newCachedThreadPool根据用户的任务数创建相应的线程来处理,该线程池不会对线程数目加以限制,完全依赖于JVM能创建线程的数量,可能引起内存不足。

  • newScheduledThreadPool创建一个至少有n个线程空间大小的线程池。此线程池支持定时以及周期性执行任务的需求。

corePoolSize和maximumPoolSize:

  • 如果当前运行的线程数小于corePoolSize,则创建新线程来处理新的任务对象,即使有其他空闲线程的存在。

  • 如果当前运行的线程数大于corePoolSize,小于maximumPoolSize时,优先向任务队列中添加任务,只有当任务队列满时,才创建新线程。

  • 如果corePoolSize等于maximumPoolSize,则意味着创建了一个固定大小的线程池。

代码演示:

Thread类,Runnable接口,Callable接口

Lock

线程池源码,几种java自带线程池的介绍

下数中的应用

相关文章

网友评论

      本文标题:多线程,以及在定时任务模块中的应用

      本文链接:https://www.haomeiwen.com/subject/dypxqqtx.html