ewoksfluo.resource_utils

Functions

array_block_size(item_shape, dtype, max_workers)	Number of items that can be processing in parallel while staying within the memory limits.
array_chunk_size(shape, dtype[, multiplier])	Process array with a chunk size along the first dimension to fit in memory.
get_available_cpus([exclude_current])	Get available CPUs.
job_parameters(narrays, shape, dtype[, ...])	Return maximum number of parallel jobs and chunk size along the first dimension so that CPU and memory usage stay within available limits.
log_required_memory(action, shape, dtype[, ...])	Log the memory required for the processing of an array.
memory_usage(msg)
peak_memory(array)