mirror of
https://gitlab.com/scemama/QCaml.git
synced 2024-12-22 04:13:33 +01:00
Better load balancing
This commit is contained in:
parent
56c8737019
commit
881db3a586
11
Basis/ERI.ml
11
Basis/ERI.ml
@ -264,7 +264,7 @@ let of_basis_parallel basis =
|
|||||||
let t0 = Unix.gettimeofday () in
|
let t0 = Unix.gettimeofday () in
|
||||||
let ishell = ref 0 in
|
let ishell = ref 0 in
|
||||||
|
|
||||||
let input_stream = Stream.of_list shell_pairs in
|
let input_stream = Stream.of_list (List.rev shell_pairs) in
|
||||||
|
|
||||||
let f shell_p =
|
let f shell_p =
|
||||||
let () =
|
let () =
|
||||||
@ -304,15 +304,6 @@ let of_basis_parallel basis =
|
|||||||
with Exit -> List.concat !result |> Array.of_list
|
with Exit -> List.concat !result |> Array.of_list
|
||||||
in
|
in
|
||||||
|
|
||||||
(*
|
|
||||||
let stream_map f stream =
|
|
||||||
let rec next i =
|
|
||||||
try Some (f (Stream.next stream))
|
|
||||||
with Stream.Failure -> None in
|
|
||||||
Stream.from next
|
|
||||||
in
|
|
||||||
stream_map f input_stream
|
|
||||||
*)
|
|
||||||
let eri_array =
|
let eri_array =
|
||||||
if Parallel.master then
|
if Parallel.master then
|
||||||
Fis.create ~size:n `Dense
|
Fis.create ~size:n `Dense
|
||||||
|
Loading…
Reference in New Issue
Block a user