Searched refs:parameter_q (Results 1 – 2 of 2) sorted by relevance
4697 if not parameter_q.qsize():4699 params = parameter_q.get()4742 parameter_q.put(params)4747 if parameter_q.qsize() > POOL_SIZE + 1:5164 parameter_q = queue_t()5177 job_parameters, parameter_q, parallelism, logger, verbose)5223 parameter_q, death_event, logger, verbose)5281 parameter_q.put(all_tasks_complete())5290 parameter_q.put(all_tasks_complete())5359 parameter_q.put(all_tasks_complete())[all …]
157 …ed_job_params_to_process_pool()`` from sending more parameters into the job queue (``parameter_q``)159 …that all jobs should finish by putting ``all_tasks_complete()`` into ``parameter_q`` but only ``de…