Callable 和 Future 是比较有趣的一对组合。当我们需要获取线程的执行结果时,就需要用到它们。Callable用于产生结果,Future用于获取结果。 第1部分 Callable Callable 是一个接口,它只包含一个call()方法。Callable是一个返回结果并且可能抛出异常的 ...
分类:
其他好文 时间:
2017-05-05 00:57:41
阅读次数:
145
Executors创建的4种线程池的使用 Java通过Executors提供四种线程池,分别为:newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。newFixedThreadPool 创建一个定长线程池,可控制线程最大 ...
分类:
编程语言 时间:
2017-04-25 16:45:51
阅读次数:
224
为了更好的控制多线程,JDK提供了一套线程框架Executor,帮助开发人员有效的进行线程控制。他们都在Java.utilconcurrent包中,是JDK并发包的核心。其中有一个比较重要的类:Executors,他扮演着线程工厂的角色,我们通过Executors可以创建特定功能的线程池。 Exec ...
分类:
其他好文 时间:
2017-04-25 00:36:31
阅读次数:
198
设计过一款基于开源的XMPP即时通信协议的软件。採用C/S协议,通过GPRS无线网络用TCP协议到server。以架设开源的Openfire server作为即时通讯平台 系统主要由下面部分组成:一是:server,负责管理发出的链接或者其他实体的会话。接收或转发XML 数据给client,它与se ...
分类:
移动开发 时间:
2017-04-23 18:49:14
阅读次数:
235
package org.rui.thread.block; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit ...
分类:
编程语言 时间:
2017-04-22 20:41:22
阅读次数:
195
背景 通过做以下一个小的接口系统gate,了解一下mina和java并发包里的东西。A系统为javaweb项目,B为C语言项目,gate是本篇须要完毕的系统。 需求 1. A为集群系统,并发较高,会批量发送给gate消息,而且接受gate返回的消息。 2. gate独立部署,将从A接受到的消息压入队 ...
分类:
编程语言 时间:
2017-04-22 19:48:27
阅读次数:
280
Executor框架是指java 5中引入的一系列并发库中与executor相关的一些功能类,其中包括线程池,Executor,Executors,ExecutorService,CompletionService,Future,Callable等。他们的关系为: 并发编程的一种编程方式是把任务拆分 ...
分类:
编程语言 时间:
2017-04-17 10:11:29
阅读次数:
232
本节介绍CompletionService,它方便了对于多个异步任务结果的处理 ...
分类:
其他好文 时间:
2017-04-14 09:41:04
阅读次数:
222
1、每当看到下面这种代码 new Thread(runnable).start() 时,请考虑用Executor 2、Executor 1)创建方式:Executors.new.. 2)通过使用Executor,可以实现各种调优、管理、监视、记录日志、错误报告 3)Executor有4个生命周期:创 ...
分类:
其他好文 时间:
2017-04-09 00:17:23
阅读次数:
191
1.通过realy机器登录relay-shell 2.登录了跳板机之后,连接可以用的机器 3.在本地的idea生成好程序的jar包(word-count_2.11-1.0.jar)之后,把jar包和需要put到远程机器的hdfs文件系统中的文件通过scp命令从开发机传到远程的机器中 4.通过put命 ...
分类:
其他好文 时间:
2017-04-05 22:29:00
阅读次数:
242