start = 0 for i in range(stream): stop = start + len(tokens[i::stream]) if tokens[start:stop]: self._task = asyncio.create_task(self._job(tokens[start:stop], i), name=str(user_id)) start = stop print('Процессы завершены')