jijzept_solver.sample_entries_utils.process_executor

Module Contents

collect_results_with_timeout(running_processes, time_limit_sec, global_start_time, status_queue=None, terminate_if_optimal=True)
Parameters:

  • running_processes (Dict[int, Tuple[Any, Any]])

  • time_limit_sec (Optional[float])

  • global_start_time (float)

  • status_queue (Optional[Any])

  • terminate_if_optimal (bool)

Return type:

Tuple[List[Tuple[bytes, List[jijzept_solver.solution_info.FeasObjectivePair], jijzept_solver.metrics.ProcessInfo]], Optional[int]]

create_signal_safe_manager()
Return type:

multiprocess.managers.SyncManager

is_force_termination_solver(process_options)

Check if the process contains solvers that require force termination on timeout.

Parameters:

process_options (Union[List[Any], Any]) – A solver option or list of solver options.

Returns:

True if any solver in the process requires force termination, False otherwise.

Return type:

bool

run_sampling_in_process(x)
send_cancel_token_to_process(process_options)

Send cancel_token to a process.

Parameters:

process_options (Union[List[Any], Any]) – A solver option or list of solver options.

Return type:

None

terminate_gracefully_and_collect_results(running_processes, result_bytes)
Parameters:
Return type:

None