[C#/.NET] 多线程处理多个队列数据的方法

复制代码
        /// <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>();

复制代码
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();
        }

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

复制代码
    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);
                }
            }
        }