快捷導(dǎo)航

c# 多線(xiàn)程處理多個(gè)數(shù)據(jù)的方法

更新時(shí)間：2021年03月31日 11:00:23 作者：conan

這篇文章主要介紹了c# 多線(xiàn)程處理多個(gè)數(shù)據(jù)的方法，幫助大家更好的理解和學(xué)習(xí)使用c#，感興趣的朋友可以了解下

概述

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

隊(duì)列（Queue）代表了一個(gè)先進(jìn)先出的對(duì)象集合。當(dāng)您需要對(duì)各項(xiàng)進(jìn)行先進(jìn)先出的訪(fǎng)問(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ī)器，我們不可能單線(xiàn)程一條一條數(shù)據(jù)的去跑，這時(shí)候就需要提高機(jī)器資源的利用率。

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

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

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

  /// <summary>
    /// 線(xiàn)程總數(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、定義線(xiàn)程列表，往線(xiàn)程添加數(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("沒(méi)有可執(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、對(duì)線(xiàn)程數(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);
        }
      }
    }