Как определить, из какого потока поступает элемент очереди в queue.get () - python
У меня есть 2 дочерних потока, которые помещают элементы (массивы) в очередь (с использованием queue.put(). Как я могу определить, из какого потока один элемент возвращается в основной поток (с помощью queue.get()).
Мне нужно знать, потому что массивы должны быть сохранены в файле в зависимости от их источника.
Ответы 1
Все очень просто: добавьте информацию в то, что вы ставите в очередь, т.е. вместо
queue.put(myarray)
использовать
queue.put({"source": whatever_identifies_your_source, "data": myarray})
Как я мог узнать, что вы должны использовать в качестве идентификатора ??? Это ваш проект, если у ты нет ответа на этот вопрос, значит, никто не знает.
мне жаль. я имею в виду, что в основном потоке я хочу сохранить эти массивы как строку в разных файлах в зависимости от того, из какого потока они берутся. поэтому, когда я получаю элементы из очереди, как именно я их разделяю на основе указанного идентификатора
я понял. но почему-то q.get({"source" : id, "data": myarray} в основном потоке ничего не делает. Не выдает ошибок, но не работает, если я print(myarray) сразу после
хорошо, я понял это, я подумал на секунду, что аргументы, которые вы помещаете в queue.put, где конкретный метод из модуля очереди. я не думал
Я передаю queue.put() только один аргумент. Разница в том, что вместо того, чтобы просто передавать массив напрямую, я заключаю его в dict (под ключом «data»), который также содержит идентификатор источника под ключом «source».
да, спасибо за ответ, работает. Я почему-то вообще не думал о словаре и подумал, что queue.put({"source": whatever_identifies_your_source, "data": myarray}) - это еще один способ передачи аргументов в функцию q.put ().
Арф! Пора выпить чашечку кофе ;-)
в поле "источник" указать идентификатор? и что мне написать в
q.get()в основном потоке, чтобы отсортировать массивы по этому идентификатору?