十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
这篇文章主要讲解了“编程中多线程的使用方法”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“编程中多线程的使用方法”吧!
成都创新互联坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站建设、网站建设、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的大悟网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
ptn多线程使用实例:
在ptn项目中由于网管系统抓取的tunnel数据量较大,每条tunnel都需要做相对于的业务处理, 传统的for循环方式中每一个tunnel去依次执行,效率很慢
现将大的tunnerl list拆分为n个list ,每个list都是一个线程,提高效率;
详情如下:
jdk 自带线程池结果管理器:ExecutorCompletionService 它将BlockingQueue 和Executor 封装起来。然后使用ExecutorCompletionService.submit()方法提交任务。
1.新建线程池
ExecutorService exs = Executors.newFixedThreadPool(analysisThreadNum);
2.线程池管理器,可以获取多线程处理结果
CompletionService
3.将一个list切分为多个list 均分tunnullist
List> averageAssign = CommUtils.averageAssign(tunnels, analysisThreadNum);
4.遍历averageAssign 均分list
List
for (List
futureList.add(completionService.submit(new LogicPathOverlappedCheckTask(list, portNameLinkIdMap,tunnelClassifyMap, allNEs, allBoards, allTopoLines)));
}
5.合并多线程处理结果
for (int i = 1, curr = 0, length = futureList.size(); i <= length; i++) {
// 采用completionService.take(),内部维护阻塞队列,任务先完成的先获取到
Map
lineNumber += MapUtils.getInteger(result, "lineNumber", 0);
boardNumber += MapUtils.getInteger(result, "boardNumber", 0);
neNumber += MapUtils.getInteger(result, "neNumber", 0);
lineResultList.addAll((List
package com.hongrant.www.comm.service.impl;
import com.hongrant.www.comm.util.DateUtils;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.*;
/**
* @author jy
* @date 2019/4/8 17:27
* ptn 逻辑同路由多线程使用借鉴
* 将一个list拆成多个list分别迭代处理每个list
*/
public class a {
public static void main(String[] args) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式
Date now = new Date(); String startTime = sdf.format(now);
System.out.println("执行开始时间"+startTime);
//准备数据
List
for (int i = 0; i <200000 ; i++) {
list.add("str:"+i+",");
}
// method1(list);
new a().method2(list);
}
public static void method1(List
//将String全部拼接展示,记录所需时间
String b = "";
//使用String拼接而不用StringBuffer 制造耗时的现象
for (String s : list) {
b+=s;
}
System.out.println(b);
}
public void method2(List
String str8="";
ExecutorService exs= Executors.newFixedThreadPool(6);
try {
CompletionService
List
//均分 List
List> avg=averageAssign(list,20);
for (List
//分开执行任务
futureList.add(completionService.submit(new strAppendTask(strings)));
}
//合并处理结果
for (int i = 1,curr=0,length=futureList.size(); i <=length; i++) {
// 采用completionService.take(),内部维护阻塞队列,任务先完成的先获取到
String s = completionService.take().get();
System.out.println("completion:"+s);
curr+=s.length();
str8+=s;
System.out.println("Thread :"+i+ "is done");
}
exs.shutdown();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}finally {
if(!exs.isShutdown()){
exs.shutdown();
}
}
System.out.println("str8="+str8);
String endTime= DateUtils.getCurrentDateTime(DateUtils.DATE_TIME_FORMAT);
System.out.println("执行结束时间"+endTime);
}
static class strAppendTask implements Callable
private List
public strAppendTask(List
this.list=strings;
}
@Override
public String call() throws Exception {
String b = "";
for (String s : list) {
b+=s;
}
System.out.println("处理完成str="+b);
return b;
}
}
/**
* 将一个list均分成n个list,主要通过偏移量来实现的
*
* @param source
* @return
*/
public static > averageAssign(List
List> result = new ArrayList
>();
if (n == 1) {
result.add(source);
return result;
}
int remaider = source.size() % n; // (先计算出余数)
int number = source.size() / n; // 然后是商
int offset = 0;// 偏移量
for (int i = 0; i < n; i++) {
List
if (remaider > 0) {
value = source.subList(i * number + offset, (i + 1) * number + offset + 1);
remaider--;
offset++;
} else {
value = source.subList(i * number + offset, (i + 1) * number + offset);
}
result.add(value);
}
return result;
}
}
感谢各位的阅读,以上就是“编程中多线程的使用方法”的内容了,经过本文的学习后,相信大家对编程中多线程的使用方法这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!