編程中多線程的使用方法

這篇文章主要講解了“編程中多線程的使用方法”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“編程中多線程的使用方法”吧！

成都創(chuàng)新互聯(lián)堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的大悟網(wǎng)站設(shè)計(jì)、移動媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

ptn多線程使用實(shí)例：
    在ptn項(xiàng)目中由于網(wǎng)管系統(tǒng)抓取的tunnel數(shù)據(jù)量較大，每條tunnel都需要做相對于的業(yè)務(wù)處理，傳統(tǒng)的for循環(huán)方式中每一個(gè)tunnel去依次執(zhí)行，效率很慢
    現(xiàn)將大的tunnerl list拆分為n個(gè)list ，每個(gè)list都是一個(gè)線程，提高效率；
    詳情如下：

jdk 自帶線程池結(jié)果管理器：ExecutorCompletionService 它將BlockingQueue 和Executor 封裝起來。然后使用ExecutorCompletionService.submit()方法提交任務(wù)。

    1.新建線程池
    ExecutorService exs = Executors.newFixedThreadPool(analysisThreadNum);

2.線程池管理器，可以獲取多線程處理結(jié)果
CompletionService<Map<String, Object>> completionService = new ExecutorCompletionService<>(exs);

    3.將一個(gè)list切分為多個(gè)list 均分tunnullist
    List<List<Tunnel>> averageAssign = CommUtils.averageAssign(tunnels, analysisThreadNum);

    4.遍歷averageAssign 均分list
    List<Future<Map<String, Object>>> futureList = new ArrayList<>();
    for (List<Tunnel> list : averageAssign) {
        futureList.add(completionService.submit(new LogicPathOverlappedCheckTask(list, portNameLinkIdMap,tunnelClassifyMap, allNEs, allBoards, allTopoLines)));
    }
    5.合并多線程處理結(jié)果
    for (int i = 1, curr = 0, length = futureList.size(); i <= length; i++) {
        // 采用completionService.take()，內(nèi)部維護(hù)阻塞隊(duì)列，任務(wù)先完成的先獲取到
        Map<String, Object> result = completionService.take().get();
        lineNumber += MapUtils.getInteger(result, "lineNumber", 0);
        boardNumber += MapUtils.getInteger(result, "boardNumber", 0);
        neNumber += MapUtils.getInteger(result, "neNumber", 0);
        lineResultList.addAll((List<Map<String, Object>>) result.get("lineResultList"));
        boardResultList.addAll((List<Map<String, Object>>) result.get("boardResultList"));
        neResultList.addAll((List<Map<String, Object>>) result.get("neResultList"));
        curr += MapUtils.getInteger(result, "listSize");
        logger.debug("Thread : " + i + " is done. [" + curr + "/" + totailNumber+ "] tunnel logic path overlapped check is done ..");
    }
    6.關(guān)閉線程池
    exs.shutdown();

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 邏輯同路由多線程使用借鑒
* 將一個(gè)list拆成多個(gè)list分別迭代處理每個(gè)list
*/
public class a {
public static void main(String[] args) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//設(shè)置日期格式
Date now = new Date(); String startTime = sdf.format(now);
System.out.println("執(zhí)行開始時(shí)間"+startTime);
//準(zhǔn)備數(shù)據(jù)
List<String> list = new ArrayList<>();
for (int i = 0; i <200000 ; i++) {
list.add("str:"+i+",");
}
// method1(list);
new a().method2(list);

}
public static void method1(List<String> list){
//將String全部拼接展示,記錄所需時(shí)間
String b = "";
//使用String拼接而不用StringBuffer 制造耗時(shí)的現(xiàn)象
for (String s : list) {
b+=s;
}
System.out.println(b);
}
public void method2(List<String> list){
String str8="";
ExecutorService exs= Executors.newFixedThreadPool(6);
try {
CompletionService<String> completionService = new ExecutorCompletionService<>(exs);
List<Future<String>> futureList = new ArrayList<>();
//均分 List<String>
List<List<String>> avg=averageAssign(list,20);
for (List<String> strings : avg) {
//分開執(zhí)行任務(wù)
futureList.add(completionService.submit(new strAppendTask(strings)));
}
//合并處理結(jié)果
for (int i = 1,curr=0,length=futureList.size(); i <=length; i++) {
// 采用completionService.take()，內(nèi)部維護(hù)阻塞隊(duì)列，任務(wù)先完成的先獲取到
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("執(zhí)行結(jié)束時(shí)間"+endTime);
}

static class strAppendTask implements Callable<String>{
private List<String > list;
public strAppendTask(List<String> strings){
this.list=strings;
}
@Override
public String call() throws Exception {
String b = "";
for (String s : list) {
b+=s;
}
System.out.println("處理完成str="+b);
return b;
}
}
/**
* 將一個(gè)list均分成n個(gè)list,主要通過偏移量來實(shí)現(xiàn)的
*
* @param source
* @return
*/
public static <T> List<List<T>> averageAssign(List<T> source, int n) {
List<List<T>> result = new ArrayList<List<T>>();
if (n == 1) {
result.add(source);
return result;
}
int remaider = source.size() % n; // (先計(jì)算出余數(shù))
int number = source.size() / n; // 然后是商
int offset = 0;// 偏移量
for (int i = 0; i < n; i++) {
List<T> value = null;
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;
}
}

感謝各位的閱讀，以上就是“編程中多線程的使用方法”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對編程中多線程的使用方法這一問題有了更深刻的體會，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點(diǎn)的文章，歡迎關(guān)注！

網(wǎng)站欄目：編程中多線程的使用方法
新聞來源：http://muchs.cn/article14/ieghde.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信小程序、網(wǎng)頁設(shè)計(jì)公司、App設(shè)計(jì)、網(wǎng)站導(dǎo)航、做網(wǎng)站、定制開發(fā)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容