diff options
| author | Michael Bebenita <[email protected]> | 2010-07-19 17:33:50 -0700 |
|---|---|---|
| committer | Michael Bebenita <[email protected]> | 2010-07-19 17:33:50 -0700 |
| commit | c80483d582b995e7890a581e7de03c70c51df137 (patch) | |
| tree | ef174a98cf18cfee3ec63b07a8b3a28554f2de51 /src/test/run-pass/task-comm-5.rs | |
| parent | Added a message passing system based on lock free queues for inter-thread com... (diff) | |
| download | rust-c80483d582b995e7890a581e7de03c70c51df137.tar.xz rust-c80483d582b995e7890a581e7de03c70c51df137.zip | |
Fixed circular buffer resizing bug.
Diffstat (limited to 'src/test/run-pass/task-comm-5.rs')
| -rw-r--r-- | src/test/run-pass/task-comm-5.rs | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/src/test/run-pass/task-comm-5.rs b/src/test/run-pass/task-comm-5.rs new file mode 100644 index 00000000..950f4149 --- /dev/null +++ b/src/test/run-pass/task-comm-5.rs @@ -0,0 +1,25 @@ +io fn main() -> () { + test00(); +} + +io fn test00() { + let int r = 0; + let int sum = 0; + let port[int] p = port(); + let chan[int] c = chan(p); + let int number_of_messages = 1000; + + let int i = 0; + while (i < number_of_messages) { + c <| i; + i += 1; + } + + i = 0; + while (i < number_of_messages) { + r <- p; sum += r; + i += 1; + } + + check (sum == ((number_of_messages * (number_of_messages - 1)) / 2)); +}
\ No newline at end of file |