C# Task Parallel Library 심화 — 병렬 처리 패턴

개요

Task Parallel Library(TPL)는 .NET에서 CPU 바운드 병렬 작업을 위한 핵심 라이브러리입니다. async/await가 I/O 바운드 비동기 작업을 담당한다면, TPL은 CPU 코어를 최대한 활용하는 데이터 병렬 처리에 특화되어 있습니다.

---

1. Parallel.For / Parallel.ForEach

using System.Threading.Tasks;

// 기본 병렬 루프
Parallel.For(0, 1000, i =>
{
    HeavyComputation(i);
});

// 병렬화 옵션 제어
var options = new ParallelOptions
{
    MaxDegreeOfParallelism = Environment.ProcessorCount / 2,
    CancellationToken = cts.Token
};

Parallel.ForEach(dataList, options, item =>
{
    Process(item);
});

---

2. Parallel.ForEachAsync (.NET 6+)

I/O 바운드 작업을 병렬로 실행할 때 사용합니다.

var urls = new[] { "https://a.com", "https://b.com", "https://c.com" };

await Parallel.ForEachAsync(urls,
    new ParallelOptions { MaxDegreeOfParallelism = 4 },
    async (url, ct) =>
    {
        var response = await httpClient.GetAsync(url, ct);
        await ProcessResponseAsync(response);
    });

---

3. PLINQ — 병렬 LINQ

using System.Linq;

// 순서 무관 병렬 처리 (가장 빠름)
var results = data
    .AsParallel()
    .Where(x => x.IsValid)
    .Select(x => Transform(x))
    .ToList();

// 순서 보존 병렬 처리
var ordered = data
    .AsParallel()
    .AsOrdered()
    .Select(x => Transform(x))
    .ToList();

// 병렬화 정도 제어
var limited = data
    .AsParallel()
    .WithDegreeOfParallelism(4)
    .Select(x => HeavyWork(x))
    .ToList();

---

4. TPL Dataflow — 파이프라인 처리

using System.Threading.Tasks.Dataflow;

// 변환 블록 정의
var downloader = new TransformBlock<string, byte[]>(
    async url => await httpClient.GetByteArrayAsync(url),
    new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 4 });

var parser = new TransformBlock<byte[], ParsedData>(
    data => Parse(data),
    new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 2 });

var saver = new ActionBlock<ParsedData>(
    async parsed => await db.SaveAsync(parsed));

// 파이프라인 연결
downloader.LinkTo(parser, new DataflowLinkOptions { PropagateCompletion = true });
parser.LinkTo(saver, new DataflowLinkOptions { PropagateCompletion = true });

// 데이터 투입
foreach (var url in urls)
    await downloader.SendAsync(url);

downloader.Complete();
await saver.Completion;

---

5. Task.WhenAll / Task.WhenAny

// 모든 작업 완료 대기
var tasks = items.Select(item => ProcessAsync(item));
var results = await Task.WhenAll(tasks);

// 가장 빠른 것 하나만 대기
var fastest = await Task.WhenAny(
    FetchFromPrimaryAsync(),
    FetchFromFallbackAsync());

var data = await fastest; // 완료된 Task의 결과 추출

---

6. 공유 상태 보호

// 잘못된 예 — 레이스 컨디션
int count = 0;
Parallel.For(0, 1000, _ => count++); // 결과 불정확

// 올바른 예 1 — Interlocked
int count = 0;
Parallel.For(0, 1000, _ => Interlocked.Increment(ref count));

// 올바른 예 2 — 로컬 합계 후 병합
long total = 0;
Parallel.For<long>(0, 1000,
    () => 0L,
    (i, _, local) => local + Compute(i),
    local => Interlocked.Add(ref total, local));

---

7. CPU 바운드 vs I/O 바운드 선택 기준

상황	권장
CPU 집약적 계산 (이미지, 암호화)	Parallel.For, PLINQ
많은 I/O 동시 실행	Parallel.ForEachAsync
단계적 데이터 처리	TPL Dataflow
단순 비동기 I/O	async/await + Task.WhenAll

---

정리

TPL은 CPU 바운드 병렬 처리의 핵심 도구입니다. Parallel.For로 반복 작업을 분산하고, Dataflow로 생산자-소비자 파이프라인을 구성하며, PLINQ로 컬렉션 변환을 병렬화하세요. 공유 상태에는 반드시 Interlocked나 스레드 로컬 합산 패턴을 사용하세요.