Event

represents an event. Clients of an event are suspended while waiting for the event to be "signaled".

Implemented using pthread_mutex and pthread_condition on Posix and CreateEvent and SetEvent on Windows.

1 import core.sync.event, core.thread, std.file;
2 
3 struct ProcessFile
4 {
5     ThreadGroup group;
6     Event event;
7     void[] buffer;
8 
9     void doProcess()
10     {
11         event.wait();
12         // process buffer
13     }
14 
15     void process(string filename)
16     {
17         event.initialize(true, false);
18         group = new ThreadGroup;
19         for (int i = 0; i < 10; ++i)
20             group.create(&doProcess);
21 
22         buffer = std.file.read(filename);
23         event.set();
24         group.joinAll();
25         event.terminate();
26     }
27 }