计算机交流平台：计算机故障_计算机论坛 www.it168bbs.com wyC#并发集合的简单方法微软对 C#(4.0)的框架添加了全新的并发 编程框架，现在我们也能用 C#开发支持并发概念的程序的。在并发编程中最让人烦恼的应该就是如何数据同步：避免脏读和脏写，当然我们可以通过 Lock 技术来实现，也可以使用微软提供给我们的并发集合，这些集合都提供了TryDo 方法。用它们对数据的读/写操作能在 TryDo 返回 True 的情况下执行。我们来看看它们吧：IProducerConsumerCollection所有的并发集合都实现了这个接口，TryAdd 和 TryTake 分别在读和写的时候判断是否能正常进行，不行则返回 false。csharppublic interface IProducerConsumerCollection : IEnumerable, ICollection, IEnumerablevoid CopyTo(T array, int index);T ToArray();bool TryAdd(T item);bool TryTake(out T item);public interface IProducerConsumerCollection : IEnumerable, ICollection, IEnumerablevoid CopyTo(T array, int index);T ToArray();bool TryAdd(T item);bool TryTake(out T item);ConcurrentQueue并发队列，队列类型的数据结构。csharppublic static void ConcurrentQueueTest()Parallel.For(1, 10000,() =while (strNornalQueue.Count != 26)if (strNornalQueue.Count = 0)for (int i = 65; i string tmp = string.Empty;tmp = head.Dequeue();Console.WriteLine(string.Format(The element 0 was set by thread 1, tmp, System.Threading.Thread.CurrentThread.ManagedThreadId);head.Enqueue(tmp);return strNornalQueue;,(result) =Console.WriteLine(-end-););Console.WriteLine(string.Format(current collection has 0 elements, Has duplicate data:1, strNornalQueue.Count, IsDuplicate(strNornalQueue.GetEnumerator();foreach (string item in strNornalQueue)Console.WriteLine(item);public static void ConcurrentQueueTest()Parallel.For(1, 10000,() =while (strNornalQueue.Count != 26)if (strNornalQueue.Count = 0)for (int i = 65; i string tmp = string.Empty;tmp = head.Dequeue();Console.WriteLine(string.Format(The element 0 was set by thread 1, tmp, System.Threading.Thread.CurrentThread.ManagedThreadId);head.Enqueue(tmp);return strNornalQueue;,(result) =Console.WriteLine(-end-););Console.WriteLine(string.Format(current collection has 0 elements, Has duplicate data:1, strNornalQueue.Count, IsDuplicate(strNornalQueue.GetEnumerator();foreach (string item in strNornalQueue)Console.WriteLine(item);ConcurrentStack并发栈，栈类型的数据结构。csharppublic static void ConcurrentStackTest()Parallel.For(1, 10000,() =while (strStack.Count != 26)if (strStack.Count = 0)for (int i = 65; i string tmp = string.Empty;if (head.TryPop(out tmp)Console.WriteLine(string.Format(The element 0 was set by thread 1, tmp, System.Threading.Thread.CurrentThread.ManagedThreadId);head.Push(tmp);elseConsole.WriteLine(queue is buzy now);return strStack;,(result) =Console.WriteLine(-end-););Console.WriteLine(string.Format(current collection has 0 elements, Has duplicate data:1, strStack.Count, IsDuplicate(strStack.GetEnumerator();foreach (string item in strStack)Console.WriteLine(item);public static void ConcurrentStackTest()Parallel.For(1, 10000,() =while (strStack.Count != 26)if (strStack.Count = 0)for (int i = 65; i string tmp = string.Empty;if (head.TryPop(out tmp)Console.WriteLine(string.Format(The element 0 was set by thread 1, tmp, System.Threading.Thread.CurrentThread.ManagedThreadId);head.Push(tmp);elseConsole.WriteLine(queue is buzy now);return strStack;,(result) =Console.WriteLine(-end-););Console.WriteLine(string.Format(current collection has 0 elements, Has duplicate data:1, strStack.Count, IsDuplicate(strStack.GetEnumerator();foreach (string item in strStack)Console.WriteLine(item);ConcurrentDictionary并发字典，字典类型的数据结构。csharppublic static void ConcurrentDictionary()for (int i = 65; i (1, 10000,() =Console.WriteLine(-start-);return strDictionary;计算机交流平台：计算机故障_计算机论坛 www.it168bbs.com wy,(index, state, head) =string tmp = string.Empty;if (head.TryRemove(Convert.ToChar(new Random().Next(65,90).ToString(), out tmp)Console.WriteLine(string.Format(The element 0 was set by thread 1, tmp, System.Threading.Thread.CurrentThread.ManagedThreadId);head.TryAdd(tmp, tmp);elseConsole.WriteLine(queue is buzy now);return strDictionary;,(result) =Console.WriteLine(-end-););public static void ConcurrentDictionary()for (int i = 65; i (1, 10000,() =Console.WriteLine(-start-);return strDictionary;,(index, state, head) =string tmp = string.Empty;if (head.TryRemove(Convert.ToChar(new Random().Next(65,90).ToString(), out tmp)Console.WriteLine(string.Format(The element 0 was set by thread 1, tmp, System.Threading.Thread.CurrentThread.ManagedThreadId);head.TryAdd(tmp, tmp);计算机交流平台：计算机故障_计算机论坛 www.it168bbs.com wyelseConsole.WriteLine(queue is buzy now);return strDictionary;,(result) =Console.WriteLine(-end-););ConcurrentBag类似堆栈的数据结构。csharppublic static void ConcurrentBag()for (int i = 65; i (1, 10000,() =return strBag;,(index, state, head) =string tmp = string.Empty;if (strBag.TryTake(