From 64ff82ecf98ceb4725f0f51c73e23d1efc2160bc Mon Sep 17 00:00:00 2001 From: Michael Bebenita Date: Tue, 24 Aug 2010 21:06:56 -0700 Subject: Implemented an lock free queue based on this paper http://www.cs.rochester.edu/~scott/papers/1996_PODC_queues.pdf, the "lock free queue" we had before wasn't lock free at all. --- src/test/run-pass/task-comm-13-thread.rs | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) create mode 100644 src/test/run-pass/task-comm-13-thread.rs (limited to 'src/test/run-pass/task-comm-13-thread.rs') diff --git a/src/test/run-pass/task-comm-13-thread.rs b/src/test/run-pass/task-comm-13-thread.rs new file mode 100644 index 00000000..0dab20ed --- /dev/null +++ b/src/test/run-pass/task-comm-13-thread.rs @@ -0,0 +1,18 @@ +use std; +import std._task; + +io fn start(chan[int] c, int start, int number_of_messages) { + let int i = 0; + while (i < number_of_messages) { + c <| start + i; + i += 1; + } +} + +fn main() -> () { + log "Check that we don't deadlock."; + let port[int] p = port(); + let task a = spawn thread "start" start(chan(p), 0, 10); + join a; + log "Joined Task"; +} \ No newline at end of file -- cgit v1.2.3