python-线程和一个while-true循环

Queue.Queue

import Queue

# Initialise queue as:
queue = Queue.Queue()
Finished = object()   # Unique marker the producer will put in the queue when finished

# Consumer:
try:
    while True:
        next_item = self.queue.get(timeout=15)
        if next_item is Finished: break
        yield next_item

except Queue.Empty:
    print "Timeout exceeded"

queue.put(item)

self.done = threading.Semaphore() self.done.release() self.done.acquire()

issue 描述在标准库中需要信号量超时。

使用time.sleep(秒)在while循环每次迭代后创建一个短暂的暂停,以放弃CPU。您必须根据任务完成后快速完成任务的重要性来设置每次迭代期间的睡眠时间。

例子:

time.clock()
while True:

    if len(self.output):
        yield self.output.pop(0)

    elif self.done or 15 < time.clock():
        if 15 < time.clock():
            yield "Maximum Execution Time Exceeded %s seconds" % time.clock()
            break

    time.sleep(0.01) # sleep for 10 milliseconds

使用互斥模块或事件/信号量

您必须在这里使用同步原语。看这里: http://docs.python.org/library/threading.html .

事件对象看起来非常简单,应该可以解决您的问题。您还可以使用条件对象或信号量。

我不会发布一个示例,因为我从未使用过事件对象,而且替代方法可能不那么简单。

编辑: 我真的不确定我理解你的问题。如果一个线程可以等到某个条件稳定下来,那么就使用同步。否则 sleep() 有人发布的解决方案会占用太多的CPU时间。