zoukankan      html  css  js  c++  java
  • c# Task多线程并行任务中等待所有线程都执行完成

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading;
    using System.Threading.Tasks;
    
    namespace ConsoleApp
    {
      class Program
      {
    
        static void Main(string[] args)
        {
          var bookShop = new BookShop();
          bookShop.Run();
        }
    
      }
    
      pulic class Book
      {
        public int Id { get; set; }
    
        public string Name { get; set; }
      }
      public class BookShop
      {
        Random rand = new Random();
        Queue<Book> queueBook = new Queue<Book>();
        int Max = 10000;
        int EachCount = 500;
        int Cur = 0;
    
        void LoadData()
        {
          if (Cur >= Max)
          {
            //when Cur>=Max,return
            Console.WriteLine("Reached max value!");
            return;
          }
          Console.WriteLine("Loading data...");
          for (int i = Cur; i < EachCount + Cur; i++)
          {
            Thread.Sleep(10);
            Console.Write(i + " ");
            //insert data into Queue<Book>
            queueBook.Enqueue(new Book { Id = i, Name = "Name_" + i });
          }
          Console.WriteLine("");
          Cur += EachCount;
          Console.WriteLine("Data loaded successful,{0}...", queueBook.Count);
        }
    
        public void Run()
        {
          LoadData();
    
          Console.WriteLine("Tasks have started...");
          do
          {
            Task[] tasks = new Task[10];
            for (int i = 0; i < 10; i++)
            {
              tasks[i] = Task.Factory.StartNew(() => DoSomeWork(1000 * 1));
            }
            //// Wait for all tasks to complete.
            Task.WaitAll(tasks);
            //when Queue<Book> is empty,reload data...
            LoadData();
          } while (queueBook.Count > 0);
          //when Cur>=Max,break the while loop
          Console.WriteLine("All tasks have completed.");
    
          Console.ReadKey();
        }
    
        void DoSomeWork(int val)
        {
          while (queueBook.Count > 0)
          {
            var m = queueBook.Dequeue();
            Console.WriteLine("DoSomeWork start,i={0},Current thread id:{1}...", m.Id, Thread.CurrentThread.ManagedThreadId);
            var sleep = rand.Next(10, 200);
            // Pretend to do something.
            Thread.Sleep(sleep);
            Console.WriteLine("DoSomeWork has completed,sleep:{0},i={1}", sleep, m.Id);
          }
        }
      }
    }
    

      C#多线程中如何等待所有线程的任务都执行完成呢?在.net 4.0以4.0+中,有Task.WaitAll(params Task[] tasks)方法来等待所有Task[],而不需要更多的操作。按照微软官方的文档,我写了一个实例来调试和说明:

  • 相关阅读:
    做个坚强的逆行者,献给终日奋斗的你我——《当幸福来敲门》
    学习jvm,关于MAT an internal error occurred during:"Parsing heap dump" from问题
    很详尽KMP算法(厉害)
    插入排序[数据结构](复习)
    JVM监控工具介绍jstack, jconsole, jinfo, jmap, jdb, jstat(复制)
    Hadoop集群配置搭建
    Tomcat IO阻塞异常
    centos通过yum安装jdk
    关于PHPExcel上传Excel单元格富文本和时间类型读取数据问题
    负载均衡集群总结(Haproxy)
  • 原文地址:https://www.cnblogs.com/deepalley/p/13216754.html
Copyright © 2011-2022 走看看