Skip to content

Commit

Permalink
initialize cur_thread, first task on thread 0
Browse files Browse the repository at this point in the history
  • Loading branch information
jamorton committed Mar 31, 2012
1 parent 8aee42a commit 9851a90
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/rt/rust_scheduler.cpp
Expand Up @@ -11,6 +11,7 @@ rust_scheduler::rust_scheduler(rust_kernel *kernel,
live_threads(num_threads),
live_tasks(0),
num_threads(num_threads),
cur_thread(0),
id(id)
{
create_task_threads();
Expand Down Expand Up @@ -87,9 +88,9 @@ rust_scheduler::create_task(rust_task *spawner, const char *name) {
{
scoped_lock with(lock);
live_tasks++;
if (++cur_thread >= num_threads)
thread_no = cur_thread++;
if (cur_thread >= num_threads)
cur_thread = 0;
thread_no = cur_thread;
}
rust_task_thread *thread = threads[thread_no];
return thread->create_task(spawner, name);
Expand Down

0 comments on commit 9851a90

Please sign in to comment.