Home | 简体中文 | 繁体中文 | 杂文 | Github | 知乎专栏 | Facebook | Linkedin | Youtube | 打赏(Donations) | About
知乎专栏

第 10 章 Java 并发编程

目录

10.1. TimeUnit
10.2. ThreadLocalRandom
10.3. 原子变量
10.3.1. AtomicInteger / AtomicLong
10.3.2. AtomicBoolean
10.3.3. AtomicReference
10.3.4. 值设置与获取操作
10.4. ReentrantLock 锁
10.5. 线程安全的 HashMap(ConcurrentHashMap)
10.5.1. 设置键与值
10.6. CopyOnWriteArraySet
10.7. 队列 / 阻塞队列
10.7.1. ConcurrentLinkedQueue 非阻塞队列
10.7.2. ArrayBlockingQueue
10.7.3. LinkedBlockingQueue
10.7.4. PriorityBlockingQueue
10.7.5. ConcurrentLinkedQueue
10.7.6. LinkedTransferQueue
10.7.7. LinkedBlockingQueue LinkedTransferQueue ConcurrentLinkedQueue
10.8. Future
10.8.1. Future + Stream 管理一组线程
10.8.2. Future + ExecutorService
10.9. FutureTask
10.10. StructuredTaskScope
10.11. CompletableFuture
10.11.1. 创建 CompletableFuture 实例,并且其他线程中使用
10.11.2. runAsync 创建没有返回值的异步任务
10.11.3. thenRun / thenRunAsync
10.11.4. supplyAsync 创建带有返回值的异步任务。
10.11.5. thenAccept / thenAcceptAsync
10.11.6. 获取结果
10.11.7. thenApply / thenApplyAsync
10.11.8. runAsync / thenAccept / thenApply 区别
10.11.9. whenComplete 任务完成时执行,并且返回结果和异常
10.11.10. 超时处理
10.11.11. 按顺序执行
10.11.12. thenCombine、thenAcceptBoth 和runAfterBoth
10.11.13. applyToEither、acceptEither和runAfterEither
10.11.14. allOf / anyOf
10.11.15. 并行执行 CompletableFuture
10.11.16. 通知完成任务
10.11.17. 异常处理
10.11.18. CompletableFuture 实现 Pipeline 流水线
10.12. java 线程池
10.12.1. newCachedThreadPool
10.12.2. 固定线程池(newFixedThreadPool)
10.12.3. Executors.newScheduledThreadPool
10.12.4. SingleThreadExecutor
10.12.5. ExecutorService 正确关闭方法
10.12.6. ForkJoinPool / ForkJoinTask
10.13. Flow
10.13.1. 自定义 Publisher / Subscriber
10.13.2. SubmissionPublisher
10.13.3. Flow.Processor
10.13.4. 订单
10.14. Java 协程

包位置 java.util.concurrent

10.1. TimeUnit

		
	try {
		TimeUnit.SECONDS.sleep(5);
	} catch (InterruptedException e) {
	}