C#のList (Concurrent Collections)入門：並行処理のための安全なデータ構造

2024年8月28日

C#プログラミングにおいて、マルチスレッド環境での安全なデータ操作は重要な課題です。今回は、この課題に対する解決策の一つである「Concurrent Collections」、特にその中でも広く使用されている「ConcurrentBag<T>」について解説します。

自己紹介

私は新卒でFAシステムの開発会社に入社した２年目エンジニアです。（2024年時点）

私はC#とVBを学習中なのでブログを見返す用のメモ代わりに活用しています。私の知識を共有し、皆様の学習のサポートとなれば幸いです。

Concurrent Collectionsとは

Concurrent Collectionsは、C#のSystem.Collections.Concurrent名前空間に含まれる、マルチスレッド環境での使用に最適化されたコレクションクラス群です。これらのコレクションは、複数のスレッドから同時にアクセスされても、データの整合性を保つように設計されています。

ConcurrentBag<T>の特徴

ConcurrentBag<T>は、Concurrent Collectionsの一つで、以下の特徴があります：

スレッドセーフ: 複数のスレッドから同時にアクセスしても安全です。
順序不定: 要素の追加順序は保持されません。
重複許容: 同じ値を持つ要素を複数含むことができます。
高性能: 内部で効率的なロック機構を使用しています。

では、実際にConcurrentBag<T>を使用するコード例を見てみましょう：

using System;
using System.Collections.Concurrent;
using System.Threading.Tasks;

class Program
{
    static void Main(string[] args)
    {
        // ConcurrentBag<T>の作成
        ConcurrentBag<int> numbers = new ConcurrentBag<int>();

        // 並行してデータを追加
        Parallel.For(0, 10, i =>
        {
            numbers.Add(i);
            Console.WriteLine($"Added: {i}");
        });

        // 要素数の表示
        Console.WriteLine($"Total count: {numbers.Count}");

        // すべての要素を表示
        Console.WriteLine("All numbers:");
        foreach (var number in numbers)
        {
            Console.WriteLine(number);
        }

        // 要素の取り出し
        if (numbers.TryTake(out int result))
        {
            Console.WriteLine($"Taken: {result}");
        }

        // 要素の参照
        if (numbers.TryPeek(out int peeked))
        {
            Console.WriteLine($"Peeked: {peeked}");
        }
    }
}

このコードでは、ConcurrentBag<T>の基本的な操作を示しています：