JUC(java.util.concurrent)

Java.util.concurrent

java.util.concurrent.atomic(原子性)

java.util.concurrent.locks(锁)

进程时一个具有一定独立功能的程序关于某个数据集合的一次运行活动,它是操作系统动态执行的基本单元,在传统的操作系统中,在传统的操作系统系统中,进程即使基本的分配单元,也是基本的执行单元

通常在一个进程中可以包含若干个线程,当然一个进程中至少有一个线程,不然没有存在的意义

,线程可以利用进程所拥有的资源,在引入线程的操作系统中,通常都是把进程作为分配资源的基本单位,而把线程作为独立运行和独立调度的基本单位

由于线程比进程更小,基本上不拥有系统资源,姑对它的调度所付出的开销就会小的多,能更高效的提高系统多个程序间的并发执行程度

指在同一时刻只能有一条指令执行，但多个进程指令被快速的轮换执行，使得在宏观上具有多个进程同时执行的效果，但在微观上并不是同时执行的，只是把时间分成若干段，使多个进程快速交替的执行。

指在同一时刻，有多条指令在多个处理器上同时执行。所以无论从微观还是从宏观来看，二者都是一起执行的。

左边小括号,写死右箭头,右边大括号 ()->{}

因为 线程异步+并发从而导致出来

继承Thread类

实现 runable接口

实现 callable接口

线程池

就类似于糖葫芦,这时有一个糖葫芦里面有4个(表示4个线程),如果第三个线程需要执行10秒,其它三个线程需要执行一秒,这时执行第三个线程的时候需要阻塞,等待第三个完成之后,之后才能继续进行,这时就需要使用 FutureTask 来控制阻塞

FutureTask 就是 把第三个阻塞的线程拆解出来 ,其它三个线程执行自己的,第三个线程独立出来,不让阻塞,最后把三个线程结果和第三个线程结果相加,就等到最终结果

结果为

CountDownLatch 主要有两个方法,当一个或多个线程调用 await方法时,这些线程会阻塞

其它线程调用countdown 方法会将计数器减一 (调用countdown 方法的线程不会阻塞)

当计数器的值变为0时,因 await方法阻塞的线程会被唤醒,继续执行

结果

结果

ArrayBlockingQueue

LinkedBlockingQueue

PriorityBlockingQueue

DelayQueue

SynchronousQueue

LinckedTransferQueue

LinkedBlockingDeque

抛出异常

特殊值

阻塞

超时

Lock 的手动传统版

阻塞队列版本

Java中的线程池是通过Executor 框架实现的,该框架中用到了 Executor , Executors , ExecutorService , ThreadPoolExecutor 这几个类

Executors.newFixedThreadPool(int)

Executor.newScheduledThreadPool()

Java8新出的 Executors.newWorkStealingPool(int)

Executors.newSingleThreadExecutor()

Executors.newCachedThreadPool()

代码

public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}

public static ExecutorService newSingleThreadExecutor() {
return new FinalizableDelegatedExecutorService
(new ThreadPoolExecutor(1, 1,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()));
}

public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>());
}

corePoolSize

maximumPoolSize

keepAliveTime

unit

workQueue

threadFactory

handler

是什么

JDK内置的拒绝策略

以上内置拒绝策略均实现了 RejectedExecutorHandler 接口

答案: 一个都不用,我们工作中只能使用自定义的

Executors 中jdk已经给你提供了,为什么不用呢?

CPU密集的意思是该任务需要大量的运算,而没有阻塞,CPU一直全速运行,CPU密集任务只有在真正的多喝CPU上才能得到加速(通过多线程)

而在单核CPU上(悲催吧),无论你开几个模拟的多线程该任务都不可能得到加速,因为CPU总的运算能力也就那些

CPU密集型任务配置尽可能少的线程数量,一般公式为 CPU核数+1个线程的线程池

由于IO密集型任务线程并不是一直在执行任务,则应配置尽可能多的线程,如 CPU核数*2

IO密集型,即该任务有大量的IO,即大量的阻塞,在单线程上运行IO密集型的任务会导致浪费大量的CPU运算能力浪费在等待

所以在IO密集型任务中使用多线程可以大大的加速程序运行,即使在单核CPU上,这种加速主要就是利用了被浪费掉的阻塞时间

参考公式 : CPU核数/1-阻塞系数  (阻塞系数在 0.8-0.9之间)

比如8核CPU: 8/1-0.9=80个线程数

函数式接口

消费型接口 -Consumer<T>

供给型接口 -Supplier<T>

函数型接口-Function<T,R>

断定型接口-Predicate<T>

what?

why?

how