最近在处理很多的数据,数据量比较大,但是处理的相对简单一些,没有什么复杂的业务逻辑,然后就使用了多线程去处理。因为一直停留在Thread和Runnable的知识中,项目中使用Callable,刚好可以学习新的东西,就使用了Callable和Future结合加上Executors.newFixedTh ...
分类:
其他好文 时间:
2017-08-27 17:05:38
阅读次数:
240
最近工作用到线程池,根据业务场景选择固定长度线程池,留作备份积累 ...
分类:
编程语言 时间:
2017-08-26 15:09:23
阅读次数:
239
/*线程池*/ /*第四种 获取线程的方法:线程池*/ 一个ExecutorService,它使用线程池的可能的某个线程之一执行每个提交的任务,通常使用 Executors 工厂方法配置(ExecutorService service = Executors.newFixedThreadPool(5 ...
分类:
编程语言 时间:
2017-08-26 11:26:55
阅读次数:
208
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadFactory { private static ExecutorService thread... ...
分类:
其他好文 时间:
2017-08-18 11:18:30
阅读次数:
170
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.lo ...
分类:
编程语言 时间:
2017-08-11 20:28:26
阅读次数:
189
FutureTask 1.可取消的异步计算,FutureTask实现了Future的基本方法,提供了start、cancel 操作,可以查询计算是否完成,并且可以获取计算 的结果。结果只可以计算完成之后去获取,get方法会阻塞当前计算没有完成的线程,一定计算完成则会立即释放。线程池submit与ex... ...
分类:
其他好文 时间:
2017-08-08 00:37:25
阅读次数:
184
Scheduler作为Storm的调度器,负责为Topology分配可用资源。 Storm提供了IScheduler接口,用户可以通过实现该接口来自定义Scheduler。 其定义如下: 真正选择哪个调度器来对Topology进行分配的方法是mk-assignments。 mk-assignment ...
分类:
Web程序 时间:
2017-07-28 16:43:29
阅读次数:
297
一、 在线程中运行任务 无限制创建线程的不足 .线程生命周期的开销很高 .资源消耗 .稳定性 二、Executor框架 Executor基于生产者-消费者模式,提交任务的操作相当于生产者。运行任务的线程则相当于消费者。 1. Executors 返回 ExecutorService 2. Execu ...
分类:
编程语言 时间:
2017-07-21 22:13:12
阅读次数:
170
java基础Exchanger的使用packagecom.java.thread.test;
importjava.util.concurrent.Exchanger;
importjava.util.concurrent.ExecutorService;
importjava.util.concurrent.Executors;
importjava.util.concurrent.Future;
publicclassExchangeerTest{
privatestaticfinalEx..
分类:
编程语言 时间:
2017-07-19 11:58:36
阅读次数:
181
一:Tomcat启动时报出错误 1:Failed to start component [StandardEngine[Catalina].StandardHost[localhost].StandardContext 05-Dec-2016 11:23:44.321 SEVERE [localho ...
分类:
其他好文 时间:
2017-07-14 23:03:26
阅读次数:
221