Searched refs:max_workers (Results 1 – 11 of 11) sorted by relevance
54 int max_workers; member825 aio = aio_task_pool_new(call_state->max_workers); in block_copy_dirty_clusters()952 .max_workers = BLOCK_COPY_MAX_WORKERS, in block_copy()974 int max_workers, int64_t max_chunk, in block_copy_async() argument984 .max_workers = max_workers, in block_copy_async()
158 job->perf.max_workers, job->perf.max_chunk, in backup_loop()416 if (perf->max_workers < 1 || perf->max_workers > INT_MAX) { in backup_job_create()
459 BackupPerf perf = { .use_copy_range = true, .max_workers = 1 }; in replication_start()
65 int max_workers, int64_t max_chunk,
49 with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor:
158 with ProcessPoolExecutor(max_workers=args.threads) as executor:
139 with ThreadPoolExecutor(max_workers=args.jobs) as executor:
2698 BackupPerf perf = { .max_workers = 64 }; in do_backup_common() 2726 perf.max_workers = backup->x_perf->max_workers; in do_backup_common()
1190 with ProcessPoolExecutor(max_workers=utils.cpu_count()) as executor:
1440 - with ThreadPoolExecutor(max_workers=5) as executor:3351 + with ThreadPoolExecutor(max_workers=5) as executor:
1062 with concurrent.futures.ThreadPoolExecutor(max_workers=nproc) as executor: