HEX
Server: LiteSpeed
System: Linux us-phx-web1284.main-hosting.eu 4.18.0-553.109.1.lve.el8.x86_64 #1 SMP Thu Mar 5 20:23:46 UTC 2026 x86_64
User: u300739242 (300739242)
PHP: 8.2.30
Disabled: system, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail
Upload Files
File: //opt/alt/python37/lib/python3.7/site-packages/jsons/__pycache__/_multitasking.cpython-37.pyc
B

�P�eZ	�@s�dZddlmZmZddlmZmZmZddlm	Z	e	dee
gef�Zeee
e
d�dd�Zee
eeefd	�d
d�Ze
e
eeeee	degd
f�d�dd�Zeee
e
e
d�dd�Zd
S)zh
PRIVATE MODULE: do not import (from) it directly.

Functionality for processing iterables in parallel.
�)�Process�Manager)�List�Callable�Union)�	Something�__getitem__)�func�obj�tasks�	task_typec		Os>t||�}t|||||||d�}x|D]}|��q&Wt|�S)N)rrr	�list_to_fillr
�args�kwargs)�_get_list_to_fill�_start_tasks�join�list)	r	r
rrrr�result�tasks_instances�task�r�D/opt/alt/python37/lib/python3.7/site-packages/jsons/_multitasking.py�
multi_tasks

r)r
r�returncCs,dgt|�}t|t�r(t�}|�|�}|S)Nr)�len�
issubclassrrr)r
rr�managerrrrrs


rrN)rrr	r
r
rcCs�g}t|t|��}||pd}	tt|�|�}
t|�|}xft|�D]Z}||
}
|d|
}||dkrp||7}|t||||
||	||fd�}|��|�|�qDW|S)N�)�targetr)�minr�int�range�_fill�start�append)rrr	r
r
rrrZ
tasks_usedZ
tasks_leftZ
slice_sizeZ	rest_size�ir$�endrrrrr(s 
r)r
r
r$r'rc
Cs<x6t||�D](}|||f|�d|i|��}	|	||<qWdS)Nr)r")
r	r
r
r$r'rrrZi_Zloadedrrrr#Fs
r#)�__doc__�multiprocessingrr�typingrrrZtypishrr!�objectZ
Subscriptable�typerrrrr#rrrr�<module>s(

"