个人简介

Echo Blog


江湖无名 安心练剑
  • JCIP-29-Executor 框架小结
    jdk8 以后的多线程处理 集合进行并行计算有两种方式:并行流和CompletableFutures。 并行流 计算密集型操作,并且没有I/O,推荐使用Stream接口。因为实现简单,同时效率也可能是最高的(如果所有的线程都是计算密集型的,那就没有必要创建比处理器核数更多的线程); CompletableFutures 如果并行的工作单元还涉及等待I/O的操作(包括网络连接等待),...
    2019-01-18 03:21:15 | Concurrency
  • JCIP-28-Executor CompletableFuture
    Future 的不足 性能 虽然Future以及相关使用方法提供了异步执行任务的能力,但是对于结果的获取却是很不方便,只能通过阻塞或者轮询的方式得到任务的结果。 阻塞的方式显然和我们的异步编程的初衷相违背,轮询的方式又会耗费无谓的CPU资源,而且也不能及时地得到计算结果,为什么不能用观察者设计模式当计算结果完成及时通知监听者呢? 多个 Future 结果之间的依赖性 Future接...
    2019-01-18 03:21:15 | Concurrency
  • JCIP-27-Executor CompletionService ExecutorCompletionService
    CompletionService 接口 定义了一系列的方法的接口。 public interface CompletionService<V> { Future<V> submit(Callable<V> task); Future<V> submit(Runnable task, V result); ...
    2019-01-18 03:21:15 | Concurrency
  • JCIP-26-Executor Future FutureTask
    Future 在Java中,如果需要设定代码执行的最长时间,即超时,可以用Java线程池ExecutorService类配合Future接口来实现。 Future接口是Java标准API的一部分,在java.util.concurrent包中。Future接口是Java线程Future模式的实现,可以来进行异步计算。 Future模式可以这样来描述:我有一个任务,提交给了Future,...
    2019-01-18 03:21:15 | Concurrency
  • JCIP-25-Executor ScheduledThreadPoolExecutor 实现定时调度
    Timer 类的不足 为什么需要 ScheduledThreadPoolExecutor? 在JDK1.5之前,我们关于定时/周期操作都是通过Timer来实现的。 但是Timer有以下几种危险 a. Timer是基于绝对时间的。容易受系统时钟的影响。 b. Timer只新建了一个线程来执行所有的TimeTask。所有TimeTask可能会相关影响 c. Timer不会捕获...
    2019-01-18 03:21:15 | Concurrency
  • JCIP-24-Timer 实现定时调度
    Timer 如果我们想定时执行一个任务,应该怎么做呢? Timer 就是一个 Java 提供的类。 入门例子 测试代码 import java.text.SimpleDateFormat; import java.util.Date; import java.util.Timer; import java.util.TimerTask; public class TimerTes...
    2019-01-18 03:21:15 | Concurrency
  • JCIP-23-Executor ThreadPoolExecutor 和 Executors
    ThreadPoolExecutor 线程池相关的处理时 Executor 的核心。 可以通过调用Executors以下静态工厂方法来创建线程池并返回一个ExecutorService对象。 接口定义 继承实现了 AbstractExecutorService。 AbstractExecutorService 中定义了一系列对于 public class ThreadPoolEx...
    2019-01-18 03:21:15 | Concurrency
  • JCIP-23-ThreadPoolExecutor 对应的拒绝策略
    介绍一下 ThreadPoolExecutor 在Java中,ThreadPoolExecutor是java.util.concurrent包下的一个类,用于创建和管理线程池以实现并发执行任务。它是Java提供的用于多线程编程的强大工具之一。 ThreadPoolExecutor提供了一种可配置的线程池实现,可以通过设置参数来控制线程池的大小、线程的创建和销毁方式,以及任务的执行策略等。...
    2019-01-18 03:21:15 | Concurrency