关于多线程的一点记录
Executors.newFixedThreadPool() 以前一直用这个 invokeAll(List<Callable> tasks) 然后顺序获取,但效果非常不好。CoreJava 说这是因为如果前面的某个任务花费了很长时间,那么就会不得不等待。
改用 ExecutorCompletionService 之后效果拔群。
ThreadPoolExecutor 这是自 Java 5 出现的线程池。关于它的原理 在这儿
ForkJoinPool 是 Java7 新出的。<<O Reilly_Java性能指南>>演示了一个例子:并行计数一个数组中大于0.5的个数。
与 ThreadPoolExecutor 的区别:
- 父任务必须等待子任务完成,用 ThreadPoolExecutor 无法高效实现
- ForkJoinPool 在数组计数的例子里比ThreadPoolExecutor慢,因为多了1.2s的GC,另外创建和管理任务对象也有额外开销。
- ForkJoinPool 实现了工作窃取,假如某个线程自己的任务跑完了,可以从别的线程任务队列里“窃取”任务。一般而言,如果任务是均衡的,使用ThreadPoolExecutor更好,如果不均衡(某些线程的任务跑起来更慢),使用ForkJoinPool更好。
Java8的 parallelStream 依赖于 ForkJoinPool,所有的ForkJoinTask都会交由一个公共的ForkJoinPool池处理,这个池是ForkJoinPool类里的一个 static 成员,大小设置成与机器CPU数量一样。
使用 jconsole 查看线程状态
垃圾回收
- 找到不再使用的对象(引用计数无法解决循环引用的问题)
- 回收他们的内存
- 对堆的内存布局进行压缩整理(整理碎片)
堆内存分为新生代和老年代,其中新生代又分为 Eden 和 Survivor
垃圾收集时应用程序线程全部停止的现象称为 Stop-the-world “时空停顿”
新生代被填满时,停止所有应用程序线程进行GC的现象叫做 MinorGC;当老年代被填满后,暂停所有应用线程,对整个堆空间回收整理的过程叫 FullGC
所有的垃圾回收算法在回收新生代时都会存在时空停顿现象
对象分配于Eden空间,新生代垃圾收集时,Eden空间中的对象要么被回收,要么被移到Survivor或是老年代空间
四种辣鸡收集器:Serial、Throughput、CMS、G1
Serial 和 Throughput 在回收新生代和老年代时都会停顿,只不过Serial都用单线程回收,Throughput都用多线程回收(-XX:+UseParallelGC)
CMS能在应用程序运行的同时回收老年代,应用程序只在 MinorGC 和后台扫描时短暂停顿,但有缺点:
- 消耗更多的CPU资源用以后台扫描和垃圾回收
- 后台线程只回收不整理,老年代的碎片会越来越多
- 如果没有足够的CPU资源来支持后台GC线程,或者老年代过度碎片化,CMS会退化到Serial,用单线程回收整理老年代后,重新恢复
G1 通过将老年代划分为不同的区域,回收时,将对象从一个区域复制到另一个区域完成回收整理。减缓了碎片化的问题
禁用显式GC:System.gc()
java -XX:+PrintCommandLineFlags -version 查看使用的垃圾收集器、堆内存大小等
堆内存调优:
- 设置堆大小。太小了内存不够用会频繁GC,太大了GC一次停顿的时间会更长
文件IO
缓冲区与通道
Buffers are an in-memory abstraction. To affect the outside world (e.g., the file or
network), we need to use a Channel, from the package java.nio.channels
.
java 1.4 引入了 NIO(non-blocking io)(java.io.File
)
java 7 NIO.2,主要存在于 java.nio
包内
基础类: Path
创建Paths.get()
、移除冗余 normalize(),
toRealPath()``、转换 onePath.relative(otherPath)
与过去 java.io.File API 的相互转化 toFile()
、toPath()
快速读写
Files.newBufferedReader/Writer()
Files.readAllLines/Bytes()
异步IO
AsynchronousFile/Socket/ServerSocketChannel
将来式
channel.open() ---> read(buffer) 得到一个 Future<>
---> while( !future.isDone() ) { doSomethingElse(); }
回调式
callback 触发回调函数
channel.open() ---> read(buffer, ... new CompletionHandler<>{ completed... failed... }
)