确保可以由多个线程填充的python队列始终被清除，而不进行轮询。
确保可以由多个线程填充的Python队列始终被清除，而不进行轮询，可以使用以下方法：
- 使用线程安全的队列：Python提供了一个线程安全的队列模块
queue，其中的Queue类可以用于多线程环境下的队列操作。可以使用Queue类的put()方法将数据放入队列，使用get()方法从队列中获取数据。这样可以确保多个线程同时操作队列时不会出现竞争条件。 - 使用条件变量：Python的
threading模块提供了Condition类，可以用于线程间的同步。可以使用Condition类的wait()方法让线程等待条件满足，使用notify()方法通知等待的线程条件已满足。可以在队列为空时，让线程等待条件满足，当有新数据放入队列时，通过notify()方法通知等待的线程。 - 使用信号量：Python的
threading模块还提供了Semaphore类，可以用于控制对共享资源的访问。可以使用Semaphore类的acquire()方法获取信号量，使用release()方法释放信号量。可以在每次向队列中放入数据时，获取信号量，当队列为空时，释放信号量。 - 使用事件对象：Python的
threading模块提供了Event类，可以用于线程间的通信。可以使用Event类的set()方法设置事件为真，使用clear()方法设置事件为假，使用wait()方法等待事件为真。可以在每次向队列中放入数据时，设置事件为真，当队列为空时，等待事件为真。
综上所述，以上方法可以确保多个线程填充的Python队列始终被清除，而不进行轮询。
腾讯云相关产品推荐：
- 云服务器（CVM）：提供高性能、可扩展的云服务器实例，适用于各种应用场景。详情请参考：云服务器产品介绍
- 云数据库MySQL版（CDB）：提供高可用、可扩展的云数据库服务，适用于存储和管理大量数据。详情请参考：云数据库MySQL版产品介绍
- 云原生容器服务（TKE）：提供高度可扩展的容器化应用管理平台，支持快速部署和管理容器化应用。详情请参考：云原生容器服务产品介绍
- 人工智能机器学习平台（AI Lab）：提供丰富的人工智能开发工具和服务，支持开发者构建和部署机器学习模型。详情请参考：人工智能机器学习平台产品介绍
- 物联网开发平台（IoT Explorer）：提供全面的物联网解决方案，支持设备接入、数据采集和应用开发。详情请参考：物联网开发平台产品介绍
相关·内容
我有下面的代码，它显示了如何始终清除队列，即使有多个线程添加到队列中。它使用递归，但while循环也可以工作。这是不是一种糟糕的做法，或者会出现这样的情况:队列可能有一个对象，并且在向队列中添加某些内容之前，它不会被拉出。这样做的主要目的是拥有一个队列，该队列确保执行顺序，而不需要使用q.get()连续
浏览 14提问于2020-04-03得票数 1
回答已采纳
1回答
多个进程(而不是线程)是否可以在阻塞模式下轮询设备描述符(例如: /dev/xyx)，并在驱动程序执行返回轮询时被唤醒？我期望多个进程在我的描述符/dev/xyz上进行轮询，在进行轮询时，驱动程序立即将它们放在来自.poll函数的等待队列中，这样它们就会阻塞，直到驱动程序返回轮询<
浏览 3提问于2011-12-27得票数 2
回答已采纳
3回答
我有一个C++11应用程序，它有一个高优先级线程在产生数据，另一个低优先级线程在使用数据(在我的例子中，是把数据写到磁盘上)。我希望确保高优先级生产者线程永远不会被阻塞，也就是说，它只使用无锁算法。使用无锁队列，我可以将数据从生产者线程推送到队列，并从消费者线程轮询数据，从而实现上述目标。我想修改我的程序，使消费者线程在不活动时阻塞，而<
浏览 1提问于2014-01-29得票数 9
3回答
编辑谢谢大家的帮助。我以前没有做过太多的线程处理。我创建了一些简单的示例"Hello“脚本，但实际上没有做任何工作。
为了帮助我理解它，我使用Nagios的二进制文件编写了一个简单的脚本来查询HTTP之类的服务。这个脚本可以工作，尽管超时时间为
浏览 1提问于2009-11-09得票数 1
回答已采纳
1回答
给定:RHEL5.3下的多线程(约20个线程) C++应用程序。在负载下测试时，top显示CPU使用率每秒在10-40%的范围内跳跃。设计非常简单-大多数线程实现了主动对象设计模式:线程有一个线程安全队列，来自其他队列的请求被推送到队列，而线程只在队列上轮询并处理传入的请求。已处理的<
浏览 2提问于2010-06-18得票数 0
2回答
同步集合列表
、、、、
正确答案第6段
队列队列=Collections.synchronizedList(新的LinkedList())；
其中的一个优点是它锁定了实例( queue )，因此您可以在队列上同步，以确保组
浏览 3提问于2013-03-17得票数 1
回答已采纳
3回答
如果一个队列要由多个线程访问，但它目前只被一个方法getNextInQueue()修改，那么同步对队列的访问最合适的形式是什么？目前，我将队列声明为ConcurrentLinkedQueue，但我不希望出现多个线程正在等待一个锁被释放的死锁。我可以处理的另一种方法是不同步队列，而是同步getNextInQueu
浏览 1提问于2012-07-11得票数 4
回答已采纳
1回答
我有一个特定的资源，可以由两种类型的任务使用: Normal Task (由多个不同的线程同时运行)和Special (特别任务)，它很少由单个线程运行。我的目标是：
特别任务也应该等待直到这个资源被释放(不受任何可能正在运行的正常任务的限制)。如果特殊任务没有运行，正常任务应
浏览 6提问于2017-04-13得票数 0
回答已采纳
1回答
我在Python2中使用多处理实现了这一点，所以在这些方面的答案会很好，但通用的解决方案也很好。在我的例子中，“线程”实际上是独立的操作系统进程，资源是网络连接(不，它不是服务器，所以(E)轮询/选择不会有帮助)。一般而言，一个线程/进程可以容纳多个资源。这里有一个天真的解决方案:将任务放在一个工作队列中，并在其上释放我的线程池。让每个
浏览 1提问于2012-06-17得票数 1
1回答
我正在创建一个自定义作业调度程序，在linux上使用python3.4中的web前端。此程序创建一个守护进程(使用者)线程，该线程等待作业在PriorityQueue中可用。这些作业可以通过web接口手动添加，后者将它们添加到队列中。当使用者线程找到作业时，它会使用subprocess.run执行一个程序，并等待它完成。可以简单地杀死子进程(所执行的程序将中小企业状态保存在文件中)，但是工作线程需要对被杀死的
浏览 3提问于2015-10-30得票数 4
回答已采纳
1回答
龙卷风/旋风中的长轮询可伸缩架构
、、、、
我想在python中使用cyclone或tornado实现长轮询，从一开始就考虑到服务的可伸缩性。客户端可能会连接到此服务数小时。我的概念是： 客户端HTTP请求将由NGINX代理(充当负载均衡器)后面的多个tornado/cyclone处理程序线程处理。将有多个用于请求的数据队列:一个用于来自所有客户端的所有未处理请求，其余的队列包含特定于每个连接的客
浏览 16提问于2020-08-23得票数 0
3回答
使用条件变量比使用互斥锁的优点
、、、、
我发现：“如果没有条件变量，程序员将需要让线程不断轮询(可能在临界区)，以检查条件是否满足。这可能非常消耗资源，因为线程将在此活动中持续忙碌。条件变量是一种在没有轮询的情况下实现相同目标的方法。”()
但是看起来互斥调用也是阻塞的(不像自旋锁)。因此，如果一个线程( T1 )因为其他线程( T2 )拥有该锁而无法获得锁，则操作系统会将T1置于睡眠状态，并且仅当T2释放该锁并且操作系统将该锁交给T1时才会将其唤醒。线程T1并不真正<em
浏览 3提问于2011-01-20得票数 38
回答已采纳
2回答
我正在模拟来自源的包，该源以给定的包/秒间隔生成包。我想创建一个操作类似于ostream对象的流类，允许使用operator<<通过它输出内容，但需要注意的是，插入的每个值都应该以指定的间隔按顺序从缓冲区释放到文件描述符。例如，我可能有一个带有文件描述符sockfd的套接字，并说：buffer<&
浏览 1提问于2011-02-18得票数 3
回答已采纳
catch (Exception e) ExceptionHandler.printException(e, "Queue", "enqueue");我的问题是，我最终得到的是“Q是空的！”isQueueEmpty()表示Q不是空的，民意测验显示是空的！谢谢。
浏览 5提问于2016-01-14得票数 0
嗯，我最初想到的是如何确定或是否是线程安全的。pubsub可能有点棘手或复杂，但pydispatcher似乎很容易实现。然后我开始想知道如何判断python模块是否是线程安全的。有什么启发式吗？
浏览 2提问于2011-09-19得票数 9
1回答
工作人员抓取它并进行图像转换。之后，工作人员将其放入OCR队列中，由OCR队列工作人员处理。现在的问题是:整个应用程序运行在一个Raspberry Pi 3上。这对于OCR来说是很小的能量。所以我决定找
浏览 6提问于2016-10-15得票数 6
回答已采纳
2回答
由于编辑部分非常疲劳，我想让用户(可能是我)的生活更轻松，这样他就不必等待每个重新源的下载。为了简单起见，我们忘记了这里的第三个任务。
我的想法是使用线程或多处理模块。有些线程(例如线程1)会预先进行“下载”，而另一个线程(例如线程2)将在已经下载的资源上与用户交互。问:我如何确保线程1始终始终领先于至少ahe
浏览 6提问于2012-05-29得票数 3
回答已采纳
2回答
我编写了一个典型的生产者-消费者程序:一个生产者，负责填充队列；一个消费者，负责排队队列。以下是我的执行情况。对于上述实现，程序有时在流程(str，vFlag)中报告错误。
浏览 0提问于2012-07-31得票数 0
回答已采纳
1回答
我有一个TreeView控件，它使用条目填充(特定目录中的每个文件都填充一个项)，还有一个线程在后台运行，它会慢慢地用额外的数据填充树中的每个节点。在每个项目被处理后，我尝试对每个项目的工作人员使用BeginInvoke，但是由于后台工作人员正在处理的节点的剪切数，这会导致GUI线程变得没有响应。GUI的单个工作项中，并使用BeginInvoke一次更新多个节点，
浏览 3提问于2011-07-04得票数 2
我正在寻找一种有效的方式来使用我的安卓应用程序的HttpClient。我在不同的活动中使用HttpClients，我只想为应用程序使用一个客户端，并在活动中传递它。尽管我看了一些答案，但我想不出一种方法来只使用一个客户端来完成我的几个活动。谢谢。
浏览 0提问于2012-04-16得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
