rust-lang/rust
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

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.

Browse Source
This commit is contained in:
Michael Bebenita
2010-08-24 21:06:56 -07:00
parent d9fe885ba5
commit 64ff82ecf9
13 changed files with 404 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/rt/rust_dom.cpp
View File

@@ -301,12 +301,14 @@ void rust_dom::send_message(rust_message *message) {
/**
* Drains and processes incoming pending messages.
*/
void rust_dom::drain_incoming_message_queue() {
void rust_dom::drain_incoming_message_queue(bool process) {
rust_message *message;
while ((message = (rust_message *) _incoming_message_queue.dequeue())) {
while (_incoming_message_queue.dequeue(&message)) {
log(rust_log::COMM, "<== processing incoming message \"%s\" 0x%"
PRIxPTR, message->label, message);
message->process();
if (process) {
message->process();
}
message->~rust_message();
this->synchronized_region.free(message);
}
@@ -454,7 +456,7 @@ rust_dom::start_main_loop()
while (n_live_tasks() > 0) {
A(this, is_deadlocked() == false, "deadlock");
drain_incoming_message_queue();
drain_incoming_message_queue(true);
rust_task *scheduled_task = schedule_task();
@@ -519,7 +521,7 @@ rust_dom::start_main_loop()
}
sync::yield();
} else {
drain_incoming_message_queue();
drain_incoming_message_queue(true);
}
reap_dead_tasks();
}