说起Java 7的Executors框架的线程池，同学们能想到有几种线程池，它们分别是什么？ 一共有四个，它们分别是Executors的 newSingleThreadPool(), newCachedThreadPool(), newFixedThreadPool()，newScheduledTh ...
分类：
编程语言 时间：
2017-09-19 00:16:07
阅读次数：
185
package three; import java.util.LinkedList; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /** * * 这个方法没有返回值，不能接到... ...
分类：
编程语言 时间：
2017-09-17 15:20:56
阅读次数：
212
基于Receivers的方法 这个方法使用了Receivers来接收数据。Receivers的实现使用到Kafka高层次的消费者API。对于所有的Receivers，接收到的数据将会保存在Spark executors中，然后由Spark Streaming启动的Job来处理这些数据。 然而，在默认 ...
分类：
其他好文 时间：
2017-09-14 16:29:12
阅读次数：
175
Java通过Executors提供四种线程池，分别为：newCachedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。newS ...
分类：
编程语言 时间：
2017-09-12 12:06:54
阅读次数：
142
import java.util.concurrent.Executor; import java.util.concurrent.Executors; public class MySearchTest2 { private final static Executor executor = Exe... ...
分类：
编程语言 时间：
2017-09-10 17:35:55
阅读次数：
259
我可以看到初始化了一个任务线程延迟调度器ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();注入到了Runnable中 核心类MyRunnable实现了Runnable和ScheduledF ...
分类：
编程语言 时间：
2017-09-08 18:04:50
阅读次数：
248
一、Executor执行器 1.Executor接口，java线程池框架中的顶层接口，提供一个execute方法来执行任务 2.任务接口 1）callable接口：提供一个call方法，具有返回值可以抛出异常 2）runnable接口：提供一个run方法，无返回值不可抛出异常 3.ExecutorS ...
分类：
编程语言 时间：
2017-09-06 19:53:02
阅读次数：
244
主题：多线程进阶多线程的一些核心内容以及要关注的细节。一、线程的实现继承thread类重写run()方法和实现Runnable接口实现run()方法注意点：new线程实例时建议加线程名和要处理下线程的中断异常（[InterruptedException]）二、不得不提的[ThreadLocal]顾名... ...
分类：
编程语言 时间：
2017-09-05 01:50:17
阅读次数：
220
多生产者多消费者模拟需求：1、创建100个订单生产者，每个生产者生产100条订单，总共会生产10000条订单，由3个消费者进行订单消费处理。2、100个订单生产者全部创建完毕，再一起生产消费订单数据 1、定义事件 2、生产者 3、消费者 4、生产者消费者启动类 ...
分类：
其他好文 时间：
2017-09-03 09:58:58
阅读次数：
208
1. 创建一个可重用固定线程集合的线程池，以共享的无界队列方式来运行这些线程。 ExecutorService threadPool = Executors.newFixedThreadPool(3);// 创建可以容纳3个线程的线程池 2. 创建一个可根据需要创建新线程的线程池，但是在以前构造的线 ...
分类：
编程语言 时间：
2017-09-02 19:04:29
阅读次数：
231
