Я перебирал некоторые из многих вопросов, связанных с кодированием. Мне было интересно, как вы собираетесь реализовать очередь, используя два стека в Python? Python – не мой самый сильный язык, поэтому мне нужна вся помощь, которую я могу получить. Как функции enqueue, dequeue и front.
У меня есть часть многопоточного кода – 3 потока, которые опросают данные из SQS и добавляют их в очередь python. 5, которые принимают сообщения из очереди python, обрабатывают их и отправляют в систему на задней панели. Вот код: python_queue = Queue.Queue() class GetDataFromSQS(threading.Thread): """Threaded Url Grab""" def __init__(self, python_queue): threading.Thread.__init__(self) self.python_queue = python_queue def run(self): […]
У меня есть ряд потоков, которые предназначены для выполнения параллельно, поскольку потоки часто предназначены для выполнения: D Если я не замедлю их, они, как правило, курят друг друга, пишут в пространство друг друга. Таким образом, когда я печатаю заявление, я вижу, что в некоторых потоках выглядит как «эхо» (а не термин кодирования, а буквальное эхо). […]
Согласно документации , существует несколько реализаций очередей. Мне интересны JoinableQueue и PriorityQueue, так как я хотел бы иметь очередь с приоритетами. Похоже, что я могу получить только одну из функций в более низких версиях. Т.е. в 3.5 я могу сделать distinciton с Queue (который является совместимым) и PriorityQueue, но в python ниже 3.5 есть JoinableQueue […]
Если существует многопоточность и одна функция, которая добавляет значение в список и другую функцию, которая принимает это значение. В чем разница: import queue scrape = queue.Queue() def scrape(): scrape.put('example') def send(): example = scrape.get() print (example) scrape = set([]) def scrape(): scrape.add('example') def send(): example = scrape.pop() print (example) Почему люди используют модуль очереди, который […]
Приношу свои извинения за длинный пост. Надеюсь, это даст достаточно контекста для решения. Я попытался создать функцию утилиты, которая будет принимать любое количество старых classmethod и classmethod их в многопоточную очередь: class QueuedCall(threading.Thread): def __init__(self, name, queue, fn, args, cb): threading.Thread.__init__(self) self.name = name self._cb = cb self._fn = fn self._queue = queue self._args = […]
Поэтому у меня есть этот вопрос, и он говорит, что создает очередь классов и делает метод dequeue и enqueue Вот что я имею до сих пор, может ли кто-нибудь направить меня на правильный путь? class queue: def __init__(self,queue): self.queue = [] def dequeue(self): if len(queue) > 0: e = queue[0] queue = list[1:len(queue)] else: return […]
Даже если я не устанавливаю поток как Daemon, не должна ли программа выходить из него однажды queue.join (), завершает и разблокирует? #!/usr/bin/python import Queue import threading import time class workerthread(threading.Thread): def __init__(self,queue): threading.Thread.__init__(self) self.queue=queue def run(self): print 'In Worker Class' while True: counter=self.queue.get() print 'Going to Sleep' time.sleep(counter) print ' I am up!' self.queue.task_done() queue=Queue.Queue() […]
Мой код выглядит следующим образом: import time, queue, threading def washer(dishes, dish_queue): for dish in dishes: print ("Washing", dish) time.sleep(1) dish_queue.put(dish) def dryer(dish_queue): while True: dish = dish_queue.get() print("Drying", dish) time.sleep(2) dish_queue.task_done() print('dryer') dish_queue = queue.Queue() for n in range(2): dryer_thread = threading.Thread(target=dryer, args=(dish_queue,)) dryer_thread.start() dishes = ['salad', 'bread', 'entree', 'desert'] washer(dishes, dish_queue) dish_queue.join() Из […]
Я пытаюсь настроить систему связанных рабочих пулов, которые выглядят так: ╭────────╮ ╭─────────╮ ╭─────────╮ │ ├──> Worker 1 ───> │ ├──> Worker 3 ───> │ │ │ Data ├──> Worker 1 ───> │ Queue ├──> Worker 3 ───> │ Queue ├───> Output │ ├──> Worker 1 ───> │ ├──> Worker 3 ───> │ │ ╰────────╯ ╰─────────╯ […]