B

�P�eZ	�@s�dZd
dl
mZmZ
d
dlmZmZmZ
d
dlm	Z	
e	dee
g
ef�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,d
g
t|�
}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
|
}||d
krp||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(










"