equal
deleted
inserted
replaced
348 fun schedule_futures task_graph = |
348 fun schedule_futures task_graph = |
349 let |
349 let |
350 val tasks = Graph.topological_order task_graph |> map_filter (fn name => |
350 val tasks = Graph.topological_order task_graph |> map_filter (fn name => |
351 (case Graph.get_node task_graph name of Task body => SOME (name, body) | _ => NONE)); |
351 (case Graph.get_node task_graph name of Task body => SOME (name, body) | _ => NONE)); |
352 |
352 |
353 val par_proofs = ! parallel_proofs; |
353 val par_proofs = ! parallel_proofs >= 1; |
354 |
354 |
355 fun fork (name, body) tab = |
355 fun fork (name, body) tab = |
356 let |
356 let |
357 val deps = Graph.imm_preds task_graph name |
357 val deps = Graph.imm_preds task_graph name |
358 |> map_filter (fn parent => |
358 |> map_filter (fn parent => |