■ 병렬 비동기 태스크에 await 연산자를 사용하는 방법을 보여준다.
▶ 예제 코드 (C#)
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 |
using System; using System.Threading; using System.Threading.Tasks; ... #region 테스트 처리하기 - Test(taskName) /// <summary> /// 테스트 처리하기 /// </summary> /// <param name="taskName">태스크명</param> /// <returns>태스크</returns> private async Task<string> Test(string taskName) { Console.WriteLine("{0} 태스크가 시작되었습니다.", taskName); await Task.Delay(TimeSpan.FromSeconds(2)); //if(taskName == "Task 2") //{ // throw new Exception("예외가 발생했습니다!"); //} return string.Format ( "[{0} 스레드] 실행 태스크 : {1}, 스레드 풀 스레드 여부 : {2}", Thread.CurrentThread.ManagedThreadId, taskName, Thread.CurrentThread.IsThreadPoolThread ); } #endregion #region 테스트 처리하기 - Test() /// <summary> /// 테스트 처리하기 /// </summary> /// <returns>태스크</returns> private Task Test() { Task containerTask = new Task ( () => { Task<string> task1 = Test("Task 1"); task1.ContinueWith ( task => { Console.WriteLine(task1.Result); Task<string> task2 = Test("Task 2"); task2.ContinueWith ( innerTask => Console.WriteLine(innerTask.Result), TaskContinuationOptions.NotOnFaulted | TaskContinuationOptions.AttachedToParent ); task2.ContinueWith ( innerTask => Console.WriteLine(innerTask.Exception.InnerException), TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.AttachedToParent ); }, TaskContinuationOptions.NotOnFaulted | TaskContinuationOptions.AttachedToParent ); task1.ContinueWith ( task => Console.WriteLine(task1.Exception.InnerException), TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.AttachedToParent ); } ); containerTask.Start(); return containerTask; } #endregion ... Task task = Test(); task.Wait(); |