[C#/TPL] Task 클래스 : 자식 태스크 실행하기

■ Task<T> 클래스를 사용해 자식 태스크를 실행하는 방법을 보여준다.

▶ 예제 코드 (C#)


using System;
using System.Threading;
using System.Threading.Tasks;

...

#region 테스트 처리하기 - Test(taskName, secondCount)

/// <summary>
/// 테스트 처리하기
/// </summary>
/// <param name="taskName">태스크명</param>
/// <param name="secondCount">초 카운트</param>
/// <returns>스레드 ID</returns>
private static int Test(string taskName, int secondCount)
{
    int  threadID           = Thread.CurrentThread.ManagedThreadId;
    bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

    Console.WriteLine
    (
        "[{0}] 스레드 ID : {1}, 스레드 풀 스레드 여부 : {2}",
        taskName,
        threadID,
        isThreadPoolThread
    );

    Thread.Sleep(TimeSpan.FromSeconds(secondCount));

    return threadID;
}

#endregion

...

Task<int> parentTask = new Task<int>
(
    () =>
    {
        Task<int> childTask = Task.Factory.StartNew
        (
            () => Test("자식 태스크 #1", 5),
            TaskCreationOptions.AttachedToParent
        );

        childTask.ContinueWith
        (
            t => Test("자식 태스크 #2", 2),
            TaskContinuationOptions.AttachedToParent
        );

        return Test("부모 태스크", 2);
    }
);

parentTask.Start();

while(!parentTask.IsCompleted)
{
    Console.WriteLine("[부모 태스크] 상태 : {0}", parentTask.Status);

    Thread.Sleep(TimeSpan.FromSeconds(0.5));
}

Console.WriteLine("[부모 태스크] 상태 : {0}", parentTask.Status);

Thread.Sleep(TimeSpan.FromSeconds(10));

using System;

using System.Threading;

using System.Threading.Tasks;

...

#region 테스트 처리하기 - Test(taskName, secondCount)

/// <summary>

/// 테스트 처리하기

/// </summary>

/// <param name="taskName">태스크명</param>

/// <param name="secondCount">초 카운트</param>

/// <returns>스레드 ID</returns>

private static int Test(string taskName, int secondCount)

{

int threadID = Thread.CurrentThread.ManagedThreadId;

bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

Console.WriteLine

(

"[{0}] 스레드 ID : {1}, 스레드 풀 스레드 여부 : {2}",

taskName,

threadID,

isThreadPoolThread

);

Thread.Sleep(TimeSpan.FromSeconds(secondCount));

return threadID;

}

#endregion

...

Task<int> parentTask = new Task<int>

(

() =>

{

Task<int> childTask = Task.Factory.StartNew

(

() => Test("자식 태스크 #1", 5),

TaskCreationOptions.AttachedToParent

);

childTask.ContinueWith

(

t => Test("자식 태스크 #2", 2),

TaskContinuationOptions.AttachedToParent

);

return Test("부모 태스크", 2);

}

);

parentTask.Start();

while(!parentTask.IsCompleted)

{

Console.WriteLine("[부모 태스크] 상태 : {0}", parentTask.Status);

Thread.Sleep(TimeSpan.FromSeconds(0.5));

}

Console.WriteLine("[부모 태스크] 상태 : {0}", parentTask.Status);

Thread.Sleep(TimeSpan.FromSeconds(10));