Mercurial > projects > ldc

comparison tango/example/synchronization/barrier.d @ 132:1700239cab2e trunk

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[svn r136] MAJOR UNSTABLE UPDATE!!! Initial commit after moving to Tango instead of Phobos. Lots of bugfixes... This build is not suitable for most things.
author lindquist
date Fri, 11 Jan 2008 17:57:40 +0100
parents
children
comparison
equal deleted inserted replaced
131:5825d48b27d1 132:1700239cab2e
1 /*******************************************************************************
2 copyright: Copyright (c) 2006 Juan Jose Comellas. All rights reserved
3 license: BSD style: $(LICENSE)
4 author: Juan Jose Comellas <juanjo@comellas.com.ar>
5 Converted to use core.sync by Sean Kelly <sean@f4.ca>
6 *******************************************************************************/
7
8 private import tango.core.sync.Barrier;
9 private import tango.core.sync.Mutex;
10 private import tango.core.Exception;
11 private import tango.core.Thread;
12 private import tango.io.Stdout;
13 private import tango.text.convert.Integer;
14 debug (barrier)
15 {
16 private import tango.util.log.Log;
17 private import tango.util.log.ConsoleAppender;
18 private import tango.util.log.DateLayout;
19 }
20
21
22 /**
23 * Example program for the tango.core.sync.Barrier module.
24 */
25 void main(char[][] args)
26 {
27 const uint MaxThreadCount = 100;
28 const uint LoopsPerThread = 10000;
29
30 debug (barrier)
31 {
32 Logger log = Log.getLogger("barrier");
33
34 log.addAppender(new ConsoleAppender(new DateLayout()));
35
36 log.info("Barrier test");
37 }
38
39 Barrier barrier = new Barrier(MaxThreadCount);
40 Mutex mutex = new Mutex();
41 uint count = 0;
42 uint correctCount = 0;
43
44 void barrierTestThread()
45 {
46 debug (barrier)
47 {
48 Logger log = Log.getLogger("barrier." ~ Thread.getThis().name());
49
50 log.trace("Starting thread");
51 }
52
53 try
54 {
55 for (uint i; i < LoopsPerThread; ++i)
56 {
57 // 'count' is a resource shared by multiple threads, so we must
58 // acquire the mutex before modifying it.
59 synchronized (mutex)
60 {
61 // debug (barrier)
62 // log.trace("Acquired mutex");
63 count++;
64 // debug (barrier)
65 // log.trace("Releasing mutex");
66 }
67 }
68
69 // We wait for all the threads to finish counting.
70 debug (barrier)
71 log.trace("Waiting on barrier");
72 barrier.wait();
73 debug (barrier)
74 log.trace("Barrier was opened");
75
76 // We make sure that all the threads exited the barrier after
77 // *all* of them had finished counting.
78 synchronized (mutex)
79 {
80 // debug (barrier)
81 // log.trace("Acquired mutex");
82 if (count == MaxThreadCount * LoopsPerThread)
83 {
84 ++correctCount;
85 }
86 // debug (barrier)
87 // log.trace("Releasing mutex");
88 }
89 }
90 catch (SyncException e)
91 {
92 Stderr.formatln("Sync exception caught in Barrier test thread {0}:\n{1}\n",
93 Thread.getThis().name, e.toString());
94 }
95 catch (Exception e)
96 {
97 Stderr.formatln("Unexpected exception caught in Barrier test thread {0}:\n{1}\n",
98 Thread.getThis().name, e.toString());
99 }
100 }
101
102 ThreadGroup group = new ThreadGroup();
103 Thread thread;
104 char[10] tmp;
105
106 for (uint i = 0; i < MaxThreadCount; ++i)
107 {
108 thread = new Thread(&barrierTestThread);
109 thread.name = "thread-" ~ format(tmp, i);
110
111 group.add(thread);
112 debug (barrier)
113 log.trace("Created thread " ~ thread.name);
114 thread.start();
115 }
116
117 debug (barrier)
118 log.trace("Waiting for threads to finish");
119 group.joinAll();
120
121 if (count == MaxThreadCount * LoopsPerThread)
122 {
123 debug (barrier)
124 log.info("The Barrier test was successful");
125 }
126 else
127 {
128 debug (barrier)
129 {
130 log.error("The Barrier is not working properly: the counter has an incorrect value");
131 assert(false);
132 }
133 else
134 {
135 assert(false, "The Barrier is not working properly: the counter has an incorrect value");
136 }
137 }
138 }