src/Pure/Concurrent/task_queue.ML
changeset 79446 ec7a1603129a
parent 78757 a094bf81a496
child 80809 4a64fc4d1cde
equal deleted inserted replaced
79442:a7241e5db601 79446:ec7a1603129a
   248 fun group_tasks (Queue {groups, ...}) gs =
   248 fun group_tasks (Queue {groups, ...}) gs =
   249   fold (fn g => fn tasks => Tasks.merge (tasks, get_tasks groups (group_id g)))
   249   fold (fn g => fn tasks => Tasks.merge (tasks, get_tasks groups (group_id g)))
   250     gs Tasks.empty
   250     gs Tasks.empty
   251   |> Tasks.dest;
   251   |> Tasks.dest;
   252 
   252 
   253 fun known_task (Queue {jobs, ...}) task = can (Task_Graph.get_entry jobs) task;
   253 fun known_task (Queue {jobs, ...}) task = Task_Graph.defined jobs task;
   254 
   254 
   255 
   255 
   256 (* job status *)
   256 (* job status *)
   257 
   257 
   258 fun ready_job (task, (Job list, (deps, _))) =
   258 fun ready_job (task, (Job list, (deps, _))) =