0

Необходимо в цикле вызывать создание тредов, но не нужно создавать их каждое прохождение цикла. Я пробовал добавлять условие, что если тредов больше n, то не надо создавать новые, но это останавливает цикл, также нельзя иметь более одного t.start(). Набросал вот такой пример:

import threading
from queue import Queue


def myfunc():
    while True:
        num = queue.get()
        print(num)
        queue.task_done()


mylist = []
for x in range(10):
    for i in range(10):
        for i in range (10):
            mylist.append(i / 10)
    queue = Queue()
    for t in range(3):
        t = threading.Thread(target=myfunc)
        t.setDaemon(True)
        t.start()
    for i in mylist:
        queue.put(i)
    queue.join()
    print(len(threading.enumerate()))

В итогде получается 31 тред, как сделать так, чтобы они создавались единожды и при этом продолжали работу с циклом?

1
  • 1
    Очевидно в начале создавать нити, в которых уже циклы.
    – 0andriy
    28 фев 2020 в 8:52

2 ответа 2

1

Возможно я неверно понял условие задачи, но думаю надо смотреть в эту сторону

from concurrent.futures.thread import ThreadPoolExecutor

COUNT_THREAD = 2
mylist = [1, 2, 3]

def func(value):
    print(value)

with ThreadPoolExecutor(COUNT_THREAD) as executor:
    m = executor.map(func, mylist)
0

Благодаря комментарию 0andriy нашел ответ.

import threading
from queue import Queue


def myfunc():
    while True:
        num = queue.get()
        print(num)
        queue.task_done()


queue = Queue()
for t in range(3):
    t = threading.Thread(target=myfunc)
    t.setDaemon(True)
    t.start()
mylist = []
for x in range(10):
    for i in range(10):
        for i in range (10):
            mylist.append(i / 10)
    for i in mylist:
        queue.put(i)
    queue.join()
    print(len(threading.enumerate()))

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.