C# 中的线程安全列表
-
C# 中带有
ConcurrentBag类的线程安全列表 -
C# 中带有
ConcurrentQueue类的线程安全列表 -
C# 中带有
SynchronizedCollection类的线程安全列表
本教程将介绍在 C# 中创建线程安全列表的方法。
C# 中带有 ConcurrentBag 类的线程安全列表
ConcurrentBag 类用于在 C# 中创建线程安全的无序数据集合。ConcurrentBag 类与 C# 中的 List 非常相似，可以在 C# 中用作线程安全列表。要使用 ConcurrentBag 类，我们必须在项目中导入 System.Collections.Concurrent 名称空间。多个线程可以同时访问 ConcurrentBag 对象，但是 ConcurrentBag 对象内部的内容只能同步修改。它使它既可以与多个线程一起用于并发操作，又可以防止意外数据丢失。以下代码示例向我们展示了如何使用 C# 中的 ConcurrentBag 类创建线程安全列表。
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
namespace thread_safe_list
{
class Program
{
static void Main(string[] args)
{
ConcurrentBag<int> numbers = new ConcurrentBag<int>();
numbers.Add(0);
numbers.Add(1);
numbers.Add(2);
numbers.Add(3);
numbers.Add(4);
numbers.Add(5);
Console.WriteLine("ConcurrentBag");
foreach(var number in numbers)
{
Console.WriteLine(number);
}
List<int> nums = new List<int>();
nums.Add(0);
nums.Add(1);
nums.Add(2);
nums.Add(3);
nums.Add(4);
nums.Add(5);
Console.WriteLine("List");
foreach (var number in nums)
{
Console.WriteLine(number);
}
}
}
}
输出：
ConcurrentBag
5
4
3
2
1
0
List
0
1
2
3
4
5
在上面的代码中，我们使用 C# 中的 ConcurrentBag 类创建了一个线程安全列表。在 ConcurrentBag 和 List 数据结构中，添加新元素 Add() 的功能相同。唯一的区别是列表遵循先进先出（FIFO）的原则，而 ConcurrentBag 遵循先进先出（LIFO）的原则。下面的代码示例中解决了此问题。
C# 中带有 ConcurrentQueue 类的线程安全列表
ConcurrentQueue 类用于在 C# 中创建线程安全队列数据结构。ConcurrentQueue 按照先进先出的原则工作，就像 C# 中的 List 一样。可以使用 ConcurrentQueue 对象代替 List 对象来创建线程安全的数据结构。请参见以下示例代码。
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
namespace thread_safe_list
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine("Concurrent Queue");
ConcurrentQueue<int> numbers = new ConcurrentQueue<int>();
numbers.Enqueue(0);
numbers.Enqueue(1);
numbers.Enqueue(2);
numbers.Enqueue(3);
numbers.Enqueue(4);
numbers.Enqueue(5);
foreach (var number in numbers)
{
Console.WriteLine(number);
}
Console.WriteLine("List");
List<int> nums = new List<int>();
nums.Add(0);
nums.Add(1);
nums.Add(2);
nums.Add(3);
nums.Add(4);
nums.Add(5);
foreach (var number in nums)
{
Console.WriteLine(number);
}
}
}
}
输出：
Concurrent Queue
0
1
2
3
4
5
List
0
1
2
3
4
5
在上面的代码中，我们使用 C# 中的 ConcurrentQueue 类创建了线程安全的 List 数据结构。List 和 ConcurrentQueue 数据结构中可用的方法之间有很多差异。例如，在 List 数据结构中添加新元素的方法是 Add()。相反，在 ConcurrentQueue 数据结构中添加新元素的方法是 Enqueue()，就像 C# 中的常规 Queue 数据结构一样。在下面的示例中解决了 ConcurrentQueue 数据结构的缺点。
C# 中带有 SynchronizedCollection 类的线程安全列表
SynchronizedCollection 类用于创建 C# 中某些指定类型的对象的线程安全集合。SynchronizedCollection 数据结构与 C# 中的 List 数据结构非常相似。两种数据结构都按照先进先出的原则工作。在 SynchronizedCollection 和 List 数据结构中添加新元素的功能是 Add()。请参见以下示例。
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
namespace thread_safe_list
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine("Synchronized Collection");
SynchronizedCollection<int> numbers = new SynchronizedCollection<int>();
numbers.Add(0);
numbers.Add(1);
numbers.Add(2);
numbers.Add(3);
numbers.Add(4);
numbers.Add(5);
foreach (var number in numbers)
{
Console.WriteLine(number);
}
Console.WriteLine("List");
List<int> nums = new List<int>();
nums.Add(0);
nums.Add(1);
nums.Add(2);
nums.Add(3);
nums.Add(4);
nums.Add(5);
foreach (var number in nums)
{
Console.WriteLine(number);
}
}
}
}
输出：
Synchronized Collection
0
1
2
3
4
5
List
0
1
2
3
4
5
在上面的代码中，我们使用 C# 中的 SynchronizedCollection 类创建了一个线程安全列表。到目前为止，此方法是在 C# 中实现列表数据结构功能的其他两种方法中最好的，因为它遵循相同的 FIFO 原理并且具有相同的方法。
Maisam is a highly skilled and motivated Data Scientist. He has over 4 years of experience with Python programming language. He loves solving complex problems and sharing his results on the internet.
LinkedIn