快捷導(dǎo)航

C#多線程處理多個(gè)隊(duì)列數(shù)據(jù)的方法

更新時(shí)間：2021年06月10日 08:55:54 作者：conan

本文將結(jié)合實(shí)例代碼，介紹C#多線程處理多個(gè)隊(duì)列數(shù)據(jù)的方法,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

概述

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

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

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

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

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

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

/// <summary> 
        /// 線程總數(shù) 
        /// </summary> 
        private int threadNum = 4; 
 
        /// <summary> 
        /// 總數(shù) 
        /// </summary> 
        private int totalCount = 0; 
 
        /// <summary> 
        /// 已處理 
        /// </summary> 
        private int index = 0; 
 
        /// <summary> 
        /// 隊(duì)列 
        /// </summary> 
        private ConcurrentQueue<AssetRepayment> queues = new ConcurrentQueue<AssetRepayment>();

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

public void SubDeTransaction() 
        { 
            var list = new List<AssetRepayment>(); 
            for (int i = 0; i < 1000; i++) 
            { 
                list.Add(new AssetRepayment() { Title = i.ToString() + "---" + Guid.NewGuid().ToString() }); 
            } 
 
            if (list == null || list.Count() == 0) 
            { 
                Console.WriteLine("沒有可執(zhí)行的數(shù)據(jù)"); 
                return; 
            } 
            totalCount = list.Count; 
            Console.WriteLine("可執(zhí)行的數(shù)據(jù):" + list.Count() + "條"); 
            foreach (var item in list) 
            { 
                queues.Enqueue(item); 
            } 
            List<Task> tasks = new List<Task>(); 
            for (int i = 0; i < threadNum; i++) 
            { 
                var task = Task.Run(() => 
                { 
                    Process(); 
                }); 
                tasks.Add(task); 
            } 
            var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) => 
            { 
            }); 
            taskList.Wait(); 
        }

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

var taskList = Task.Factory.ContinueWhenAll(tasks.ToArray(), (ts) => 
            { 
            }); 
            taskList.Wait();

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

private void Process() 
        { 
            while (true) 
            { 
                var currentIndex = Interlocked.Increment(ref index); 
                AssetRepayment repayId = null; 
                var isExit = queues.TryDequeue(out repayId); 
                if (!isExit) 
                { 
                    break; 
                } 
                try 
                { 
                    Console.WriteLine(repayId.Title); 
 
                    Console.WriteLine(string.Format(" 共{0}條 當(dāng)前第{1}條", totalCount, currentIndex)); 
                } 
                catch (Exception ex) 
                { 
                    Console.WriteLine(ex); 
                } 
            } 
        }

運(yùn)行測試

代碼地址

https://gitee.com/conanOpenSource_admin/Example

到此這篇關(guān)于C#多線程處理多個(gè)隊(duì)列數(shù)據(jù)的方法的文章就介紹到這了,更多相關(guān)C#多線程處理多個(gè)隊(duì)列數(shù)據(jù)的方法內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: