日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
C#多線程處理多個(gè)隊(duì)列數(shù)據(jù)的方法

[[389656]]

本文轉(zhuǎn)載自微信公眾號(hào)「后端Q」，作者conan。轉(zhuǎn)載本文請(qǐng)聯(lián)系后端Q公眾號(hào)。 

站在用戶的角度思考問(wèn)題，與客戶深入溝通，找到魏都網(wǎng)站設(shè)計(jì)與魏都網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗(yàn)，讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個(gè)性化、用戶體驗(yàn)好的作品，建站類(lèi)型包括：網(wǎng)站建設(shè)、做網(wǎng)站、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、空間域名、虛擬主機(jī)、企業(yè)郵箱。業(yè)務(wù)覆蓋魏都地區(qū)。

概述

多線程(multithreading)，是指從軟件或者硬件上實(shí)現(xiàn)多個(gè)線程并發(fā)執(zhí)行的技術(shù)。具有多線程能力的計(jì)算機(jī)因有硬件支持而能夠在同一時(shí)間執(zhí)行多于一個(gè)線程，進(jìn)而提升整體處理性能。具有這種能力的系統(tǒng)包括對(duì)稱(chēng)多處理機(jī)、多核心處理器以及芯片級(jí)多處理或同時(shí)多線程處理器。在一個(gè)程序中，這些獨(dú)立運(yùn)行的程序片段叫作“線程”(Thread)，利用它編程的概念就叫作“多線程處理”。

隊(duì)列(Queue)代表了一個(gè)先進(jìn)先出的對(duì)象集合。當(dāng)您需要對(duì)各項(xiàng)進(jìn)行先進(jìn)先出的訪問(wèn)時(shí)，則使用隊(duì)列。當(dāng)您在列表中添加一項(xiàng)，稱(chēng)為入隊(duì)，當(dāng)您從列表中移除一項(xiàng)時(shí)，稱(chēng)為出隊(duì)。

比如平常我們?cè)谔幚矶〞r(shí)任務(wù)的時(shí)候，假設(shè)就一臺(tái)機(jī)器，我們不可能單線程一條一條數(shù)據(jù)的去跑，這時(shí)候就需要提高機(jī)器資源的利用率。

下面我們來(lái)介紹下，如何實(shí)現(xiàn)多線程+隊(duì)列以提高并發(fā)處理能力。

代碼實(shí)現(xiàn)

1、定義線程數(shù)threadNum和隊(duì)列queues

 
 
 
 
      
  
  
  
  1. ///  
    2.   
  
  
  
  2.         /// 線程總數(shù) 
    3.   
  
  
  
  3.         ///  
    4.   
  
  
  
  4.         private int threadNum = 4; 
    5.   
  
  
  
  5.  
    6.   
  
  
  
  6.         ///  
    7.   
  
  
  
  7.         /// 總數(shù) 
    8.   
  
  
  
  8.         ///  
    9.   
  
  
  
  9.         private int totalCount = 0; 
    10.   
  
  
  
  10.  
    11.   
  
  
  
  11.         ///  
    12.   
  
  
  
  12.         /// 已處理 
    13.   
  
  
  
  13.         ///  
    14.   
  
  
  
  14.         private int index = 0; 
    15.   
  
  
  
  15.  
    16.   
  
  
  
  16.         ///  
    17.   
  
  
  
  17.         /// 隊(duì)列 
    18.   
  
  
  
  18.         ///  
    19.   
  
  
  
  19.         private ConcurrentQueue queues = new ConcurrentQueue(); 
    20.

2、定義線程列表，往線程添加數(shù)據(jù)

 
 
 
 
      
  
  
  
  1. public void SubDeTransaction() 
    2.   
  
  
  
  2.         { 
    3.   
  
  
  
  3.             var list = new List(); 
    4.   
  
  
  
  4.             for (int i = 0; i < 1000; i++) 
    5.   
  
  
  
  5.             { 
    6.   
  
  
  
  6.                 list.Add(new AssetRepayment() { Title = i.ToString() + "---" + Guid.NewGuid().ToString() }); 
    7.   
  
  
  
  7.             } 
    8.   
  
  
  
  8.  
    9.   
  
  
  
  9.             if (list == null || list.Count() == 0) 
    10.   
  
  
  
  10.             { 
    11.   
  
  
  
  11.                 Console.WriteLine("沒(méi)有可執(zhí)行的數(shù)據(jù)"); 
    12.   
  
  
  
  12.                 return; 
    13.   
  
  
  
  13.             } 
    14.   
  
  
  
  14.             totalCount = list.Count; 
    15.   
  
  
  
  15.             Console.WriteLine("可執(zhí)行的數(shù)據(jù):" + list.Count() + "條"); 
    16.   
  
  
  
  16.             foreach (var item in list) 
    17.   
  
  
  
  17.             { 
    18.   
  
  
  
  18.                 queues.Enqueue(item); 
    19.   
  
  
  
  19.             } 
    20.   
  
  
  
  20.             List tasks = new List(); 
    21.   
  
  
  
  21.             for (int i = 0; i < threadNum; i++) 
    22.   
  
  
  
  22.             { 
    23.   
  
  
  
  23.                 var task = Task.Run(() => 
    24.   
  
  
  
  24.                 { 
    25.   
  
  
  
  25.                     Process(); 
    26.   
  
  
  
  26.                 }); 
    27.   
  
  
  
  27.                 tasks.Add(task); 
    28.   
  
  
  
  28.             } 
    29.   
  
  
  
  29.             var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) => 
    30.   
  
  
  
  30.             { 
    31.   
  
  
  
  31.             }); 
    32.   
  
  
  
  32.             taskList.Wait(); 
    33.   
  
  
  
  33.         } 
    34.

3、對(duì)線程數(shù)進(jìn)行限制 for (int i = 0; i < threadNum; i++)

 
 
 
 
      
  
  
  
  1. var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) => 
    2.   
  
  
  
  2.             { 
    3.   
  
  
  
  3.             }); 
    4.   
  
  
  
  4.             taskList.Wait(); 
    5.

4、從隊(duì)列取出數(shù)據(jù)進(jìn)行業(yè)務(wù)處理

 
 
 
 
      
  
  
  
  1. private void Process() 
    2.   
  
  
  
  2.         { 
    3.   
  
  
  
  3.             while (true) 
    4.   
  
  
  
  4.             { 
    5.   
  
  
  
  5.                 var currentIndex = Interlocked.Increment(ref index); 
    6.   
  
  
  
  6.                 AssetRepayment repayId = null; 
    7.   
  
  
  
  7.                 var isExit = queues.TryDequeue(out repayId); 
    8.   
  
  
  
  8.                 if (!isExit) 
    9.   
  
  
  
  9.                 { 
    10.   
  
  
  
  10.                     break; 
    11.   
  
  
  
  11.                 } 
    12.   
  
  
  
  12.                 try 
    13.   
  
  
  
  13.                 { 
    14.   
  
  
  
  14.                     Console.WriteLine(repayId.Title); 
    15.   
  
  
  
  15.  
    16.   
  
  
  
  16.                     Console.WriteLine(string.Format(" 共{0}條 當(dāng)前第{1}條", totalCount, currentIndex)); 
    17.   
  
  
  
  17.                 } 
    18.   
  
  
  
  18.                 catch (Exception ex) 
    19.   
  
  
  
  19.                 { 
    20.   
  
  
  
  20.                     Console.WriteLine(ex); 
    21.   
  
  
  
  21.                 } 
    22.   
  
  
  
  22.             } 
    23.   
  
  
  
  23.         } 
    24.

運(yùn)行測(cè)試

代碼地址

https://gitee.com/conanOpenSource_admin/Example


網(wǎng)站題目：C#多線程處理多個(gè)隊(duì)列數(shù)據(jù)的方法
URL網(wǎng)址：http://m.5511xx.com/article/cdddjpd.html