TASK Archives - icodebroker

[C#/WINUI3/.NET8] TaskCompletionSource 클래스 : SetResult 메소드/Task 속성을 사용해 비동기 작업 처리하기

■ TaskCompletionSource<T> 클래스의 SetResult 메소드/Task 속성을 사용해 비동기 작업을 처리하는 방법을 보여준다. ▶ Program.cs


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

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 작업 처리하기 - ProcessOperationAsync()

    /// <summary>
    /// 작업 처리하기
    /// </summary>
    /// <returns>작업 처리 결과 태스크</returns>
    private static Task<int> ProcessOperationAsync()
    {
        TaskCompletionSource<int> taskCompletionSource = new TaskCompletionSource<int>();

        Task.Run
        (
            async () =>
            {
                int mainThreadID = Thread.CurrentThread.ManagedThreadId;

                Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 비동기 작업 시작");

                await Task.Delay(3000);

                taskCompletionSource.SetResult(42);

                Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 비동기 작업 완료");
            }
        );

        return taskCompletionSource.Task;
    }

    #endregion

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    /// <returns>태스크</returns>
    private static async Task Main()
    {
        int mainThreadID = Thread.CurrentThread.ManagedThreadId;

        Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 프로그램 시작");

        Task<int> task = ProcessOperationAsync();

        for(int i = 0; i < 50; i++)
        {
            Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 항목 {i}");

            await Task.Delay(100);
        }

        int result = await task;

        Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 비동기 작업 결과 : {result}");

        Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 프로그램 종료");
    }

    #endregion
}

using System;

using System.Threading;

using System.Threading.Tasks;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 작업 처리하기 - ProcessOperationAsync()

/// <summary>

/// 작업 처리하기

/// </summary>

/// <returns>작업 처리 결과 태스크</returns>

private static Task<int> ProcessOperationAsync()

{

TaskCompletionSource<int> taskCompletionSource = new TaskCompletionSource<int>();

Task.Run

(

async () =>

{

int mainThreadID = Thread.CurrentThread.ManagedThreadId;

Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 비동기 작업 시작");

await Task.Delay(3000);

taskCompletionSource.SetResult(42);

Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 비동기 작업 완료");

}

);

return taskCompletionSource.Task;

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

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

private static async Task Main()

{

int mainThreadID = Thread.CurrentThread.ManagedThreadId;

Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 프로그램 시작");

Task<int> task = ProcessOperationAsync();

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

{

Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 항목 {i}");

await Task.Delay(100);

}

int result = await task;

Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 비동기 작업 결과 : {result}");

Console.WriteLine($"[{DateTime.Now.ToString("HH:mm:ss")}] 스레드 ID : {mainThreadID}, 프로그램 종료");

}

#endregion

}

TestProject.zip

[C#/WINUI3/.NET8] _ (discard) 연산자 사용하기

■ _ (discard) 연산자를 사용하는 방법을 보여준다. ※ await 키워드를 사용하지 않는다. ※ 대화 상자를 표시하는 비동기 작업을 시작하지만, 완료를 기다리지 않는다.

[C#/WINUI3/.NET8] IAsyncOperation 인터페이스 : AsTask 메소드를 사용해 Task 객체 구하기

■ IAsyncOperation<T> 인터페이스의 AsTask 메소드를 사용해 Task<T> 객체를 구하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System.Threading.Tasks;

using Windows.Foundation;
using Windows.Storage;

StorageFolder storageFolder = await StorageFolder.GetFolderFromPathAsync(@"D:\");

IAsyncOperation<IStorageItem> storageItemAsyncOperation = storageFolder.TryGetItemAsync("sample.dat");

Task<IStorageItem> task = storageItemAsyncOperation.AsTask();

using System.Threading.Tasks;

using Windows.Foundation;

using Windows.Storage;

StorageFolder storageFolder = await StorageFolder.GetFolderFromPathAsync(@"D:\");

IAsyncOperation<IStorageItem> storageItemAsyncOperation = storageFolder.TryGetItemAsync("sample.dat");

Task<IStorageItem> task = storageItemAsyncOperation.AsTask();

[C#/WINUI3/COMMUNITY TOOLKIT/.NET8] DispatcherQueueExtensions 클래스 : EnqueueAsync 확장 메소드를 사용해 DispatcherQueue 객체에서 특정 UI 스레드 실행하기

■ DispatcherQueueExtensions 클래스의 EnqueueAsync 확장 메소드를 사용해 DispatcherQueue 객체에서 특정 UI 스레드를 실행하는 방법을 보여준다. ▶ 예제 코드 (C#)


using System.Threading.Tasks;

using Microsoft.UI.Dispatching;
using Microsoft.UI.Xaml.Controls;

using CommunityToolkit.WinUI;

DispatcherQueue dispatcherQueue = DispatcherQueue.GetForCurrentThread();

await dispatcherQueue.EnqueueAsync
(
    () =>
    {
    }
);

int value1 = await dispatcherQueue.EnqueueAsync
(
    () =>
    {
        return 42;
    }
);

await dispatcherQueue.EnqueueAsync
(
    async () =>
    {
        await Task.Delay(100);
    }
);

int someOtherValue = await dispatcherQueue.EnqueueAsync
(
    async () =>
    {
        await Task.Delay(100);

        return 42;
    }
);

using System.Threading.Tasks;

using Microsoft.UI.Dispatching;

using Microsoft.UI.Xaml.Controls;

using CommunityToolkit.WinUI;

DispatcherQueue dispatcherQueue = DispatcherQueue.GetForCurrentThread();

await dispatcherQueue.EnqueueAsync

(

() =>

{

}

);

int value1 = await dispatcherQueue.EnqueueAsync

(

() =>

{

return 42;

}

);

await dispatcherQueue.EnqueueAsync

(

async () =>

{

await Task.Delay(100);

}

);

int someOtherValue = await dispatcherQueue.EnqueueAsync

(

async () =>

{

await Task.Delay(100);

return 42;

}

);