기존 이벤트와 병행 런타임에서 제공하는 이벤트에는 한가지 중요한 차이점이 있습니다. 새로운 이벤트는 병행 런타임을 인식하여 작업이 블록되는 경우 다른 작업에 스레드를 양보(yield)합니다. 무조건 선점형으로 동작하는 기존 Win32 이벤트보다 더 지능적이고 효율적으로 동작하는 것이죠.
자, 그럼 코드를 살펴봅시다. 이 예제에서는 스케줄러의 병렬성을 2로 제한하고 그보다 많은 수의 작업을 병행 수행할 때, 기존 Win32 이벤트와 병행 런타임 이벤트를 각각 활용하는 경우 어떤 차이가 있는지 보여줍니다.
1 // event.cpp : Defines the entry point for the console application.
2 //
3 // compile with: /EHsc
4 #include <windows.h>
5 #include <concrt.h>
6 #include <concrtrm.h>
7 #include <ppl.h>
8
9 using namespace Concurrency;
10 using namespace std;
11
12 class WindowsEvent
13 {
14 HANDLE m_event;
15 public:
16 WindowsEvent()
17 :m_event(CreateEvent(NULL,TRUE,FALSE,TEXT("WindowsEvent")))
18 {
19 }
20
21 ~WindowsEvent()
22 {
23 CloseHandle(m_event);
24 }
25
26 void set()
27 {
28 SetEvent(m_event);
29 }
30
31 void wait(int count = INFINITE)
32 {
33 WaitForSingleObject(m_event,count);
34 }
35 };
36
37 template<class EventClass>
38 void DemoEvent()
39 {
40 EventClass e;
41 volatile long taskCtr = 0;
42
43 //태스크그룹을 생성하고 여러 태스크 사본을 스케줄링합니다.
44 task_group tg;
45 for(int i = 1;i <= 8; ++i)
46 tg.run([&e,&taskCtr]{
47
48 //작업 부하를 시뮬레이션합니다.
49 Sleep(100);
50
51 //태스크 카운터를 증가시킵니다.
52 long taskId = InterlockedIncrement(&taskCtr);
53 printf_s("\tTask %d waiting for the event\n", taskId);
54
55 e.wait();
56
57 printf_s("\tTask %d has received the event\n", taskId);
58
59 });
60
61 //이벤트를 셋하기 전에 충분히 시간을 보냅니다.
62 Sleep(1500);
63
64 printf_s("\n\tSetting the event\n");
65
66 //이벤트를 셋
67 e.set();
68
69 //작업들의 완료를 대기
70 tg.wait();
71 }
72
73 int main ()
74 {
75 //스레드 둘만을 활용하는 스케줄러를 생성합니다.
76 CurrentScheduler::Create(SchedulerPolicy(2, MinConcurrency, 2, MaxConcurrency, 2));
77
78 //협력적 이벤트를 사용할 경우, 모든 작업들이 시작됩니다.
79 printf_s("Cooperative Event\n");
80 DemoEvent<event>();
81
82 //기존 이벤트를 사용하면, Win7 x64 환경이 아닌한
83 //ConcRT가 블록 상황을 인식하지 못하여 첫 두 작업만이 시작됩니다.
84 printf_s("Windows Event\n");
85 DemoEvent<WindowsEvent>();
86
87 return 0;
88 }
WindowsEvent 클래스는 기존 Win32 이벤트를 위한 랩퍼(wrapper) 클래스입니다. DemoEvent 함수 템플릿이 사용할 이벤트 형을 템플릿 인자로 받아 실제 작업을 하는 놈입니다. PPL(Parallel Patterns Library)의 task를 이용해 8개 작업을 만들고 각각에서 이벤트를 기다리도록 하고 있습니다.
결과는 다음과 같이 나올 겁니다.
병렬성이 둘로 제한되는 상황에서도 병행 런타임의 이벤트를 사용할 경우 각 작업이 블록될 경우 다른 작업에 스레드를 양보하기 때문에 8개의 작업이 모두 시작되는 것을 확인하실 수 있습니다. 반면, 기존 이벤트의 경우 두 작업만이 시작되었다가 이벤트를 받고 두 작업이 종료된 후에나 다른 작업들이 시작되는 것을 확인하실 수 있습니다.
'VC++ 10 Concurrency Runtime' 카테고리의 다른 글
| Parallel Patterns Library(PPL) - 병렬 알고리즘 (0) | 2009.08.19 |
|---|---|
| Parallel Patterns Library(PPL) - Task (2) | 2009.08.18 |
| Parallel Patterns Library (PPL) (1) | 2009.08.06 |
| Concurrency Runtime (7) | 2009.07.30 |
| PPL task를 이용한 피보나치 수 계산 (3) | 2009.07.17 |
