page contents

c# 多线程处理多个并发数据的方法

本文讲述了c# 多线程处理多个并发数据的方法！具有很好的参考价值，希望对大家有所帮助。一起跟随六星小编过来看看吧，具体如下:

attachments-2022-05-iXxEQVV062957913a73a3.png

本文讲述了c# 多线程处理多个并发数据的方法！具有很好的参考价值，希望对大家有所帮助。一起跟随六星小编过来看看吧，具体如下:

多线程（multithreading），是指从软件或者硬件上实现多个线程并发执行的技术。具有多线程能力的计算机因有硬件支持而能够在同一时间执行多于一个线程，进而提升整体处理性能。具有这种能力的系统包括对称多处理机、多核心处理器以及芯片级多处理或同时多线程处理器。在一个程序中，这些独立运行的程序片段叫作“线程”（Thread），利用它编程的概念就叫作“多线程处理”。

队列（Queue）代表了一个先进先出的对象集合。当您需要对各项进行先进先出的访问时，则使用队列。当您在列表中添加一项，称为入队，当您从列表中移除一项时，称为出队。

比如平常我们在处理定时任务的时候，假设就一台机器，我们不可能单线程一条一条数据的去跑，这时候就需要提高机器资源的利用率。

下面我们来介绍下，如何实现多线程+队列以提高并发处理能力。

代码实现

1、定义线程数threadNum和队列queues

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
/// <summary>
  /// 线程总数
  /// </summary>
  private int threadNum = 4;
 
  /// <summary>
  /// 总数
  /// </summary>
  private int totalCount = 0;
 
  /// <summary>
  /// 已处理
  /// </summary>
  private int index = 0;
 
  /// <summary>
  /// 队列
  /// </summary>
  private ConcurrentQueue<AssetRepayment> queues = new ConcurrentQueue<AssetRepayment>();

2、定义线程列表，往线程添加数据

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
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("没有可执行的数据");
      return;
    }
    totalCount = list.Count;
    Console.WriteLine("可执行的数据:" + 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、对线程数进行限制 for (int i = 0; i < threadNum; i++) 

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

4、从队列取出数据进行业务处理

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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}条 当前第{1}条", totalCount, currentIndex));
      }
      catch (Exception ex)
      {
        Console.WriteLine(ex);
      }
    }
  }

更多相关技术内容咨询欢迎前往并持续关注六星社区了解详情。

想高效系统的学习Python编程语言，推荐大家关注一个公众号：Python编程学习圈。每天分享行业资讯、技术干货供大家阅读，关注即可免费领取整套Python入门到进阶的学习资料以及教程，感兴趣的小伙伴赶紧行动起来吧。

attachments-2022-05-rLS4AIF8628ee5f3b7e12.jpg

  • 发表于 2022-05-31 10:11
  • 阅读 ( 2015 )
  • 分类：C/C++开发

你可能感兴趣的文章

相关问题

0 条评论

请先 登录 后评论
轩辕小不懂
轩辕小不懂

2403 篇文章

作家榜 »

  1. 轩辕小不懂 2403 文章
  2. 小柒 1478 文章
  3. Pack 1135 文章
  4. Nen 576 文章
  5. 王昭君 209 文章
  6. 文双 71 文章
  7. 小威 64 文章
  8. Cara 36 文章

轩辕小不懂

如果觉得我的文章对您有用，请随意打赏。你的支持将鼓励我继续创作！