TPL Archives - 5 중 5 번째 페이지

[C#/TPL] Task 클래스 : ContinueWith 메소드 사용하기

■ Task<T> 클래스의 ContinueWith 메소드를 사용하는 방법을 보여준다. ▶ 예제 코드 (C#)


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

...

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

/// <summary>
/// 테스트 1 처리하기
/// </summary>
/// <param name="taskName">태스크명</param>
/// <param name="secondCount">초 카운트</param>
/// <returns>스레드 ID</returns>
private static int Test1(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
#region 테스트 2 처리하기 - Test2(taskName, precedingTask)

/// <summary>
/// 테스트 2 처리하기
/// </summary>
/// <param name="taskName">태스크명</param>
/// <param name="precedingTask">선행 태스크</param>
private static void Test2(string taskName, Task<int> precedingTask)
{
    int  threadID           = Thread.CurrentThread.ManagedThreadId;
    bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

    Console.WriteLine
    (
        "[{0}] 선행 태스크 스레드 ID : {1}, 스레드 ID : {2}, 스레드 풀 스레드 여부 : {3}",
        taskName,
        precedingTask.Result,
        threadID,
        isThreadPoolThread
    );
}

#endregion

...

Task<int> task1 = new Task<int>(() => Test1("태스크 #1", 3));
Task<int> task2 = new Task<int>(() => Test1("태스크 #2", 2));

task1.ContinueWith(t => Test2("태스크 #3", t), TaskContinuationOptions.OnlyOnRanToCompletion);
task2.ContinueWith(t => Test2("태스크 #4", t), TaskContinuationOptions.OnlyOnRanToCompletion);

task1.Start();
task2.Start();

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

Console.WriteLine("작업을 완료했습니다.");

using System;

using System.Threading;

using System.Threading.Tasks;

...

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

/// <summary>

/// 테스트 1 처리하기

/// </summary>

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

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

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

private static int Test1(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

#region 테스트 2 처리하기 - Test2(taskName, precedingTask)

/// <summary>

/// 테스트 2 처리하기

/// </summary>

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

/// <param name="precedingTask">선행 태스크</param>

private static void Test2(string taskName, Task<int> precedingTask)

{

int threadID = Thread.CurrentThread.ManagedThreadId;

bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

Console.WriteLine

(

"[{0}] 선행 태스크 스레드 ID : {1}, 스레드 ID : {2}, 스레드 풀 스레드 여부 : {3}",

taskName,

precedingTask.Result,

threadID,

isThreadPoolThread

);

}

#endregion

...

Task<int> task1 = new Task<int>(() => Test1("태스크 #1", 3));

Task<int> task2 = new Task<int>(() => Test1("태스크 #2", 2));

task1.ContinueWith(t => Test2("태스크 #3", t), TaskContinuationOptions.OnlyOnRanToCompletion);

task2.ContinueWith(t => Test2("태스크 #4", t), TaskContinuationOptions.OnlyOnRanToCompletion);

task1.Start();

task2.Start();

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

Console.WriteLine("작업을 완료했습니다.");

[C#/TPL] Task 클래스 : RunSynchronously 메소드를 사용해 태스크 실행하기

■ Task<T> 클래스의 RunSynchronously 메소드를 사용해 태스크를 실행하는 방법을 보여준다. ▶ 예제 코드 (C#)


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

...

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

/// <summary>
/// 테스트 처리하기
/// </summary>
/// <param name="taskName">태스크명</param>
/// <returns>처리 결과</returns>
private int Test(string taskName)
{
    int  threadID           = Thread.CurrentThread.ManagedThreadId;
    bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

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

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

    return DateTime.Now.Millisecond;
}

#endregion

...

Task<int> task = new Task<int>(() => Test("태스크 #1"));

task.RunSynchronously();

Console.WriteLine("[태스크 #1] 처리 결과 : {0}", task.Result);

Console.WriteLine("작업을 완료했습니다.");

using System;

using System.Threading;

using System.Threading.Tasks;

...

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

/// <summary>

/// 테스트 처리하기

/// </summary>

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

/// <returns>처리 결과</returns>

private int Test(string taskName)

{

int threadID = Thread.CurrentThread.ManagedThreadId;

bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

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

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

return DateTime.Now.Millisecond;

}

#endregion

...

Task<int> task = new Task<int>(() => Test("태스크 #1"));

task.RunSynchronously();

Console.WriteLine("[태스크 #1] 처리 결과 : {0}", task.Result);

Console.WriteLine("작업을 완료했습니다.");

[C#/TPL] Task 클래스 : Start 메소드를 사용해 태스크 실행하기

■ Task<T> 클래스의 Start 메소드를 사용해 태스크를 실행하는 방법을 보여준다. ▶ 예제 코드 (C#)


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

...

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

/// <summary>
/// 테스트 처리하기
/// </summary>
/// <param name="taskName">태스크명</param>
/// <returns>처리 결과</returns>
private int Test(string taskName)
{
    int  threadID           = Thread.CurrentThread.ManagedThreadId;
    bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

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

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

    return DateTime.Now.Millisecond;
}

#endregion

...

Task<int> task = new Task<int>(() => Test("태스크 #1"));

task.Start();

// 아래 문장에서 task.Result를 참조하기 때문에 메인 스레드가 봉쇄 상태에서 기다린다.
Console.WriteLine("[태스크 #1] 처리 결과 : {0}", task.Result);

Console.WriteLine("작업을 완료했습니다.");

using System;

using System.Threading;

using System.Threading.Tasks;

...

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

/// <summary>

/// 테스트 처리하기

/// </summary>

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

/// <returns>처리 결과</returns>

private int Test(string taskName)

{

int threadID = Thread.CurrentThread.ManagedThreadId;

bool isThreadPoolThread = Thread.CurrentThread.IsThreadPoolThread;

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

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

return DateTime.Now.Millisecond;

}

#endregion

...

Task<int> task = new Task<int>(() => Test("태스크 #1"));

task.Start();

// 아래 문장에서 task.Result를 참조하기 때문에 메인 스레드가 봉쇄 상태에서 기다린다.

Console.WriteLine("[태스크 #1] 처리 결과 : {0}", task.Result);

Console.WriteLine("작업을 완료했습니다.");

[C#/TPL] async … await 키워드 사용하기

■ async … await 키워드를 사용하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

...

private ListBox listBox;
private TextBox textBox;

...

#region 버튼 클릭시 처리하기 - button_Click(sender, e)

/// <summary>
/// 버튼 클릭시 처리하기
/// </summary>
/// <param name="sender">이벤트 발생자</param>
/// <param name="e">이벤트 인자</param>
async private void button_Click(object sender, EventArgs e)
{
    await AddItemAsync(this.textBox.Text, 10);
}

#endregion

#region 항목 비동기 추가하기 - AddItemAsync(message, count)

/// <summary>
/// 항목 비동기 추가하기
/// </summary>
/// <param name="message">메시지</param>
/// <param name="count">카운트</param>
/// <returns>태스크</returns>
private Task AddItemAsync(string message, int count)
{
    return Task.Run(() =>
    {
        for(int i = 0; i < count; i++)
        {
            this.listBox.Items.Add(message + ", " + i.ToString());

            Thread.Sleep(500);
        }
    });
}

#endregion

using System;

using System.Threading;

using System.Threading.Tasks;

using System.Windows.Forms;

...

private ListBox listBox;

private TextBox textBox;

...

#region 버튼 클릭시 처리하기 - button_Click(sender, e)

/// <summary>

/// 버튼 클릭시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

async private void button_Click(object sender, EventArgs e)

{

await AddItemAsync(this.textBox.Text, 10);

}

#endregion

#region 항목 비동기 추가하기 - AddItemAsync(message, count)

/// <summary>

/// 항목 비동기 추가하기

/// </summary>

/// <param name="message">메시지</param>

/// <param name="count">카운트</param>

/// <returns>태스크</returns>

private Task AddItemAsync(string message, int count)

{

return Task.Run(() =>

{

for(int i = 0; i < count; i++)

{

this.listBox.Items.Add(message + ", " + i.ToString());

Thread.Sleep(500);

}

});

}

#endregion

[C#/TPL] async … await 키워드 사용하기

■ async … await 키워드를 사용하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

...

private ListBox listBox;
private TextBox textBox;

...

#region 버튼 클릭시 처리하기 - button_Click(sender, e)

/// <summary>
/// 버튼 클릭시 처리하기
/// </summary>
/// <param name="sender">이벤트 발생자</param>
/// <param name="e">이벤트 인자</param>
async private void button_Click(object sender, EventArgs e)
{
    await AddItemAsync(this.textBox.Text, 10);
}

#endregion

#region 항목 비동기 추가하기 - AddItemAsync(message, count)

/// <summary>
/// 항목 비동기 추가하기
/// </summary>
/// <param name="message">메시지</param>
/// <param name="count">카운트</param>
/// <returns>태스크</returns>
private Task AddItemAsync(string message, int count)
{
    Action action = delegate()
    {
        for(int i = 0; i < count; i++)
        {
            this.listBox.Items.Add(message +", " + i.ToString());

            Thread.Sleep(500);
        }
    };

    Task task = new Task(action);

    task.Start();

    return task;
}

#endregion

using System;

using System.Threading;

using System.Threading.Tasks;

using System.Windows.Forms;

...

private ListBox listBox;

private TextBox textBox;

...

#region 버튼 클릭시 처리하기 - button_Click(sender, e)

/// <summary>

/// 버튼 클릭시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

async private void button_Click(object sender, EventArgs e)

{

await AddItemAsync(this.textBox.Text, 10);

}

#endregion

#region 항목 비동기 추가하기 - AddItemAsync(message, count)

/// <summary>

/// 항목 비동기 추가하기

/// </summary>

/// <param name="message">메시지</param>

/// <param name="count">카운트</param>

/// <returns>태스크</returns>

private Task AddItemAsync(string message, int count)

{

Action action = delegate()

{

for(int i = 0; i < count; i++)

{

this.listBox.Items.Add(message +", " + i.ToString());

Thread.Sleep(500);

}

};

Task task = new Task(action);

task.Start();

return task;

}

#endregion

[C#/TPL] async … await 키워드 사용하기

■ async … await 키워드를 사용하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;

...

private ListBox listBox;
private TextBox textBox;

...

#region 버튼 클릭시 처리하기 - button_Click(sender, e)

/// <summary>
/// 버튼 클릭시 처리하기
/// </summary>
/// <param name="sender">이벤트 발생자</param>
/// <param name="e">이벤트 인자</param>
async private void button_Click(object sender, EventArgs e)
{
    await Task.Run(() =>
    {
            for(int i = 0; i < 10; i++)
            {
                this.listBox.Items.Add(this.textBox.Text + ", " + i.ToString());

                Thread.Sleep(500);
            }
    });
}

#endregion

using System;

using System.Threading;

using System.Threading.Tasks;

using System.Windows.Forms;

...

private ListBox listBox;

private TextBox textBox;

...

#region 버튼 클릭시 처리하기 - button_Click(sender, e)

/// <summary>

/// 버튼 클릭시 처리하기

/// </summary>

/// <param name="sender">이벤트 발생자</param>

/// <param name="e">이벤트 인자</param>

async private void button_Click(object sender, EventArgs e)

{

await Task.Run(() =>

{

for(int i = 0; i < 10; i++)

{

this.listBox.Items.Add(this.textBox.Text + ", " + i.ToString());

Thread.Sleep(500);

}

});

}

#endregion