JAVA线程池之newFixedThreadPool实战
java线程池之newfixedthreadpool实战
1.线程池分类:
fixthreadpool 定长线程池,cachedthreadpool 缓存线程池,scheduledthreadpool 定时线程池,singlethreadpool单线程的线程池
下面创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。示例代码如下:
package test;
import java.util.arraylist;
import java.util.hashmap;
import java.util.list;
import java.util.map;
import java.util.concurrent.callable;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
import java.util.concurrent.future;
import java.util.concurrent.timeunit;
public class fixedthreadpooltest {
// 定长线程池
executorservice fixedthreadpool = executors.newfixedthreadpool(2);
/**
* 超时时间/分钟
*/
public static final int timeout = 5;
public void testfixedthreadpool() {
list<map<string, string>> list = new arraylist<map<string, string>>();
map<string, string> map1 = new hashmap<string, string>();
map1.put("applno", "666");
list.add(map1);
map<string, string> map2 = new hashmap<string, string>();
map2.put("applno", "667");
list.add(map2);
map<string, string> map3 = new hashmap<string, string>();
map3.put("applno", "668");
list.add(map3);
list<callable<boolean>> callablelist = new arraylist<callable<boolean>>();
if (list.size() > 0) {
system.out.println("执行次数:" + list.size());
for (final map map : list) {
callable<boolean> call = new callable<boolean>() {
@override
public boolean call() throws exception {
try {
return doyoumethod();
} catch (exception e) {
system.out.println("执行异常:" + e);
return null;
}
}
};
callablelist.add(call);
}
}
try {
list<future<boolean>> futurelist = fixedthreadpool.invokeall(callablelist);
for (future<boolean> future : futurelist) {
boolean flag = future.get(timeout, timeunit.minutes);
if (flag) {
system.out.println(" 成功");
} else {
system.out.println(" 失败");
}
}
} catch (exception e) {
system.out.println(" ----- 异常 -----" + e.getmessage());
}
}
public boolean doyoumethod() {
system.out.println(thread.currentthread().getname());
system.out.println("执行你的方法");
return true;
}
public static void main(string[] args) {
fixedthreadpooltest ft = new fixedthreadpooltest();
ft.testfixedthreadpool();
}
}
上一篇: 瞬间感觉威严尽失
下一篇: 中间的那只鸭子在干什么呢?