线程锁

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections.Concurrent; //引用命名空间
using System.Threading;
using System.Diagnostics;
using System.Threading.Tasks;

namespace 线程锁新概念
{
    class Program
    {
        private static object obj = new object();

        private static Queue<Product> _queue = null; //一般队列Queue
        private static ConcurrentQueue<Product> _currentQueue = null; //多线程安全下的队列
        private static List<Task> taskList = new List<Task>();
        private static List<Task> curtaskList = new List<Task>();
        static void Main(string[] args)
        {
            //第一种并发执行
            Thread.Sleep(1000);
            _queue = new Queue<Product>();
            Stopwatch watch = new Stopwatch(); //统计时间消耗
            watch.Start();
            for (int i = 0; i < 3; i++)
            {
                
                //Action actPro = new Action(AddProducts); //调用第一种方法
                //IAsyncResult resultPro = actPro.BeginInvoke(null, null);
                //actPro.EndInvoke(resultPro);
                
                taskList.Add(Task.Factory.StartNew(AddProducts));
                
            }
            //在等待之前这里还可以做别的事
            Console.WriteLine("这里还可以做别的事儿。。。");

            Task.WaitAll(taskList.ToArray());
            watch.Stop();
            Console.WriteLine("当前数据量为{0}", _queue.Count);
            Console.WriteLine("用lock锁的情况下使用时间为{0}", watch.ElapsedMilliseconds);
            Console.WriteLine();

            //第二种并发执行
            Thread.Sleep(1000);
            _currentQueue = new ConcurrentQueue<Product>();
            Stopwatch watchCur = new Stopwatch();
            watchCur.Start();
            for (int i = 0; i < 3; i++)
            {
                //Action actCurpro = new Action(AddConcurrentProduct); //调用第二种方法
                //IAsyncResult result = actCurpro.BeginInvoke(null, null);
                //actCurpro.EndInvoke(result);
                curtaskList.Add(Task.Factory.StartNew(AddConcurrentProduct));
            }
            //在等待之前这里还可以做别的事
            Console.WriteLine("这里还可以做别的事儿。。。");

            Task.WaitAll(curtaskList.ToArray());
            watchCur.Stop();
            Console.WriteLine("当前数据量为{0}", _currentQueue.Count);
            Console.WriteLine("用ConcurrentQueue的情况下使用时间为{0}", watchCur.ElapsedMilliseconds);
            Console.ReadLine();
        }

        /// <summary>
        /// 在lock加锁的情况下并行执行
        /// </summary>
        static void AddProducts()
        {
            Parallel.For(0, 30000, (i) =>
            {
                Product product = new Product();
                product.Name = "name" + i;
                product.Category = "Category" + i;
                product.SellPrice = i;
                lock (obj)
                {
                    _queue.Enqueue(product);
                }
            });
            Console.WriteLine("当前线程ID为{0}", Thread.CurrentThread.ManagedThreadId);
        }

        /// <summary>
        /// 在不加锁的情况下并行执行
        /// </summary>
        static void AddConcurrentProduct()
        {
            Parallel.For(0, 30000, (i) =>
            {
                Product product = new Product();
                product.Name = "name" + i;
                product.Category = "Category" + i;
                product.SellPrice = i;
                _currentQueue.Enqueue(product);
            });
            Console.WriteLine("当前线程ID为{0}", Thread.CurrentThread.ManagedThreadId);
        }
    }
    class Product
    {
        public string Name { get; set; }
        public string Category { get; set; }
        public int SellPrice { get; set; }
    }
}