X-Git-Url: http://git.megacz.com/?a=blobdiff_plain;f=rts%2FTask.c;h=4a630843b725cec6aa1afaff7e26417dac2a06ae;hb=a89ac49312ff740591226f0a6fd9322f15289c62;hp=588d414d875a9d20232a1cfd678a017442ecaaeb;hpb=ab0e778ccfde61aed4c22679b24d175fc6cc9bf3;p=ghc-hetmet.git diff --git a/rts/Task.c b/rts/Task.c index 588d414..4a63084 100644 --- a/rts/Task.c +++ b/rts/Task.c @@ -68,21 +68,30 @@ initTaskManager (void) void stopTaskManager (void) { - Task *task, *next; - debugTrace(DEBUG_sched, "stopping task manager, %d tasks still running", tasksRunning); + /* nothing to do */ +} + + +void +freeTaskManager (void) +{ + Task *task, *next; + + debugTrace(DEBUG_sched, "freeing task manager"); ACQUIRE_LOCK(&sched_mutex); - for (task = task_free_list; task != NULL; task = next) { - next = task->next; + for (task = all_tasks; task != NULL; task = next) { #if defined(THREADED_RTS) closeCondition(&task->cond); closeMutex(&task->lock); #endif + next = task->all_link; stgFree(task); } + all_tasks = NULL; task_free_list = NULL; RELEASE_LOCK(&sched_mutex); } @@ -243,6 +252,11 @@ workerTaskStop (Task *task) taskTimeStamp(task); task->stopped = rtsTrue; tasksRunning--; + + ACQUIRE_LOCK(&sched_mutex); + task->next = task_free_list; + task_free_list = task; + RELEASE_LOCK(&sched_mutex); } void