网站建设样本,易推广,办一年宽带多少钱,网站域名注册步骤Java-线程池 原子性 类线程池构造方法调用Executors静态方法创建调用方法直接创建线程池对象原子性volatile-问题出现原因:volatile解决原子性AtomicInteger的常用方法悲观锁和乐观锁synchronized(悲)和CAS(乐)的区别并发工具类Hashtable集合ConcurrentHashMap原理:CountDownLa…
Java-线程池 原子性 类线程池构造方法调用Executors静态方法创建调用方法直接创建线程池对象原子性volatile-问题出现原因:volatile解决原子性AtomicInteger的常用方法悲观锁和乐观锁synchronized(悲)和CAS(乐)的区别并发工具类Hashtable集合ConcurrentHashMap原理:CountDownLatch方法Semaphore方法:线程池
构造方法
调用Executors静态方法创建
创建一个默认无限大小的线程池最大不超过int的范围:static ExecutorService newCachedThreadPool() 例:ExecutorService es Executors.newCachedThreadPool();创建一个指定大小最多线程数量的线程池:static newFixedThreadPool(int nThreads) 例:ExecutorService es Executors.newCachedThreadPool();调用方法
Future? submit(Runnable task) // 提交一个 Runnable 任务用于执行,()里可以传一个λ表达式,也可以传实现Runnable对象void shutdown 关闭线程池使用Executors中所提供的静态方法来创建
直接创建线程池对象
ThreadPoolExecutor threadPoolExecutor new ThreadPoolExecutor(核心线程数量,最大线程数量,空闲线程最大存活时间,任务队列,创建线程工厂,任务的拒绝策略);
参数一核心线程数量 -------------- 核心线程数量 (不能小于0)参数二最大线程数 -------------- 线程池中最大线程的数量 (不能小于等于0最大数量 核心线程数量)参数三空闲线程最大存活时间 -------------- 空闲时间值 (不能小于0)参数四时间单位 -------------- 空闲时间单位 (时间单位)(秒:TimeUnit.SECONDS 分:TimeUnit.MINUTES 时:TimeUnit.HOURS ...)参数五任务队列 -------------- 阻塞队列 (不能为null)(new ArrayBlockingQueue(int capacity)) //任务队列参数六创建线程工厂 -------------- 创建线程的方式 (不能为null)(Executors.defaultThreadFactory())参数七任务的拒绝策略 -------------- 要执行的任务过多时的解决方案 (不能为null)(new ThreadPoolExecutor.AbortPolicy())任务的拒绝策略ThreadPoolExecutor.AbortPolicy: 丢弃任务并抛出RejectedExecutionException异常。--是默认的策略。ThreadPoolExecutor.DiscardPolicy 丢弃任务但是不抛出异常 这是不推荐的做法。ThreadPoolExecutor.DiscardOldestPolicy 抛弃队列中等待最久的任务 然后把当前任务加入队列中。ThreadPoolExecutor.CallerRunsPolicy: 调用任务的run()方法绕过线程池直接执行。原子性
volatile-问题
出现原因:
当A线程修改了共享数据时B线程没有及时获取到最新的值如果还在使用原先的值就会出现问题 1 堆内存是唯一的每一个线程都有自己的线程栈。2 每一个线程在使用堆里面变量的时候都会先拷贝一份到变量的副本中。3 在线程中每一次使用是从变量的副本中获取的。volatile解决
Volatile关键字 :强制线程每次在使用的时候都会看一下共享区域最新的值例: public static volatile int money 1000; //每个线程使用前都会重新获取此值原子性
所有的操作全部都得到了执行并且不会受到任何因素的干扰而中断,是一个不可分割的整体AtomicInteger的常用方法
public AtomicInteger() //初始化一个默认值为0的原子型Integer
public AtomicInteger(int initialValue) //初始化一个指定值的原子型IntegerAtomicBoolean 原子更新布尔类型 //与AtomicInteger相似AtomicLong 原子更新长整型 //与AtomicInteger相似int get(): //获取值int getAndIncrement(): //以原子方式将当前值加1注意这里返回的是自增前的值。int incrementAndGet(): //以原子方式将当前值加1注意这里返回的是自增后的值。int addAndGet(int data): //以原子方式将输入的数值与实例中的值AtomicInteger里的value相加并返回结果。int getAndSet(int value): //以原子方式设置为newValue的值并返回旧值。悲观锁和乐观锁
synchronized(悲)和CAS(乐)的区别
相同点在多线程情况下都可以保证共享数据的安全性。不同点synchronized总是从最坏的角度出发认为每次获取数据的时候别人都有可能修改。所以在每次操作共享数据之前都会上锁。悲观锁cas是从乐观的角度出发假设每次获取数据别人都不会修改所以不会上锁。只不过在修改共享数据的时候会检查一下别人有没有修改过这个数据。
如果别人修改过那么我再次获取现在最新的值。
如果别人没有修改过那么我现在直接修改共享数据的值.(乐观锁乐观锁1 只针对 值的修改 只在修改处 加校验。 具体大段的逻辑 他不管。2 针对 多查 少改。
悲观锁(synchronized)1 针对 大段的逻辑 上下文关联的并发工具类
Hashtable集合
HashMap 线程不安全的 效率比较高。 开发中在局部位置定义双列集合首选HashMap因为局部位置不涉及共享数据 属于单线程开发使用HashMap效率最高。Hashtable 每个方法都是 同步方法,用synchronized修饰 。 效率比较低ConcurrentHashMap
线程安全 效率较高原理:
jdk1.7之前原理使用的 哈希表的嵌套 并使用悲观锁synchronized对 小哈希表进行局部锁定所以他可以同时使用16条线程共同操作此集合。
jdk1.8之后的原理对横向的数组数据 使用乐观锁cas对竖向的链表和红黑树 使用悲观锁synchronized 锁对象是红黑树或者链表的头结点。CountDownLatch
可以设置 某一线程 等待其他几条线程结束之后 再开始执行方法
构造方法:
public CountDownLatch(int count) 参数传递线程数表示等待线程数量成员方法:
public void await() 让线程等待
public void countDown() 当前线程执行完毕Semaphore
限制同一时间线程执行的个数,可以控制访问特定资源的线程数量。方法:
构造方法:
public Semaphore(int count) // 参数传递可执行的线程数量方法:
public void acquire() //从此信号量获取一个许可在提供一个许可前一直将线程阻塞
public void release() //释放一个许可将其返回给信号量。
