2回答
explored:该代码返回一个无限循环，其中frontier.get()似乎不会从队列中删除该项这使得while循环无限，因为队列中的第一个值始终是函数输入中定义的start节点。变量state在每个while循环中都是相同的(始终是start节点)。
我做错了什么？根据我的理解，队列应该从开始节点移动到开始节点的邻居，因
浏览 11提问于2017-01-28得票数 1
回答已采纳
1回答
如何锁定一个线程的队列？
、、、
我有一个队列，其中有几个生产者和使用者线程，它们添加和删除项。每隔一段时间，另一个线程需要锁定队列，删除和处理队列中的每个项，然后将队列释放回其余线程。如何在queue.get()的连续调用之间继续阻塞其他线程。
浏览 4提问于2022-07-15得票数 0
回答已采纳
asyncio.Queue get()方法将从队列中移除和返回一个项。 但我只想读取项目，而不是删除它。我该怎么做？queue = asyncio.Queue()
result = await queue.get() 在这里，我只想知道结果的值，但不想从队列中删除它。
浏览 119提问于2021-08-08得票数 1
1回答
因此，我现在有一个包含messages的列表，我的python需要从服务器X传输到许多其他的(比如队列系统)。global_queue = []
async def Queue(action=None, globalmsg=None, original=No
浏览 1提问于2021-10-27得票数 0
回答已采纳
这是关于multiprocessing.Queue.get的官方文档
从队列中移除并返回项。如果可选的args块为True (默认值)，而超时值为None (默认值)，则在必要时阻塞，直到某个项为available。否则(块为False)，如果其中一个是immediately available，则返回一个项，否则引发Queue.Empty异常(在这种情况下，超时将被忽略)。
浏览 1提问于2016-08-05得票数 0
2回答
生产者侦听一个套接字，该套接字接收大量TCP消息(每分钟10,000条)，读取这些数据并将其放入队列中供工作人员使用。我所设置的从队列中读取的工人如下：work_iterations = 0 try: data= queue.get(block=False) do_work(data) tim
浏览 2提问于2013-07-29得票数 0
# do work continue
self.dir_q.get()
文档说，如果我们没有给出任何东西，那么如果队列中有一些东西
浏览 0提问于2013-03-03得票数 1
回答已采纳
我希望在一个新进程中在python中运行一个函数，做一些工作，使用队列将进度返回到主进程，然后等待主进程终止所产生的进程，然后继续执行主进程。我得到了以下代码，它在新进程中运行函数foo，并使用队列返回进度：import time
for i*编辑
问题是，如果队列是空的，直到一个项被放入队列中，我才知道queue.get</
浏览 2提问于2021-04-23得票数 0
回答已采纳
1回答
在未来包装队列
、、、、
在queue.get期间，我还没有想出如何在不阻塞龙卷风的情况下做到这一点。我认为正确的解决方案是在某种将来包装get调用。我已经试了好几个小时了，但还没弄清楚该怎么做。在我的多处理脚本中： multiprocessing.Process
浏览 2提问于2018-11-26得票数 0
回答已采纳
1回答
另外，要收回这些提要并使用多个工作进程将它们推送到数据库中。下面的尝试代码适用于提要进程，而不是工作进程(Es)中的queue.get()。queue): while True: data = queue.getexception: no description
File "/Users/user/sandbox
浏览 9提问于2022-09-11得票数 0
假设我们有一个multiprocessing.Pool，其中工作线程共享一个multiprocessing.JoinableQueue，去排队工作项，并潜在地对更多的工作进行排队： while True: for new_work in process(work):queue.put(new_work)当队列被填满时，queue.put()将阻塞。只要至少有一个进
浏览 0提问于2019-04-27得票数 0
回答已采纳
1回答
我以(priority,data)的形式在优先级队列中添加数据，但是当我使用get()函数时，我将返回优先级而不是数据。
浏览 3提问于2014-03-02得票数 0
回答已采纳
1回答
data,csvfolder,result,'dosomething'))dos.join()print('finished')
然后，在剂量测量中，_exit_function“/usr/lib/python3.5 3.5/multiprocessing/util.py”中，第314行，在_exit_function _run_finalizers/util.py“中，第186行
浏览 2提问于2017-06-16得票数 0
回答已采纳
2回答
我正在使用一组希望并行运行的作业填充一个队列，并使用python的多处理模块来完成此任务。import Queuejobs = [['a', 'b'], ['c', 'd']] queue.put(job)['a', 'b']
为什么队列中没有填充所有作业？
浏览 1提问于2011-04-01得票数 5
回答已采纳
我想我在中发现了一个bug，但是由于椅子和键盘之间总是存在问题，而不是在代码中，所以我想在这里确认一下，而不是马上提交一张票子。Collect all results在这段代码中，我尝试在内存中创建图像(numpy.ones([100, 100, 3]).astype(numpy.float32))，但这并没有产生错误。
我用C++编写了类似的代码，它运行得很好。我的环
浏览 3提问于2015-08-07得票数 4
我有两个子线程，将项(数组)放入一个队列(使用queue.put()。我如何知道哪一个线程返回了一个单独的项(使用queue.get())。
我需要知道，因为数组必须根据它们的源保存在文件中。
浏览 0提问于2018-06-05得票数 1
在我的代码中，我使用了几个执行繁重任务的工作进程和一个将结果持久化到磁盘的写入器进程。要写入的数据通过队列从工作进程发送到写入器进程。更准确地说，下面这段代码 try: break
except Exception我还实现了一个日志记录进程，它输出队列的状态，并且，即使我得到上面的超时错误消息，对qsize()的调用也会不断地返回一个完整的队列(在我的例子中</em
浏览 0提问于2017-05-22得票数 9
1回答
总共，我在多个目录中得到了大约900个文件(总共大约13 got )。主脚本确定所有的文件并将它们存储在4个块中。每个块(文件列表)提供给一个进程。之后，从队列中读取restuls并将其存储到输出文件中。现在我的问题是:脚本启动这4个进程，每个进程运行到100% (参见workPackage函数中的打印)。
浏览 3提问于2018-01-15得票数 0
回答已采纳
通常，我们将其编码如下： job = queue.get()for job in queue.get():我想这么做的真正原因是因为我想使用progressbar的自动检测maxval
浏览 6提问于2014-01-16得票数 37
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号