Python教程

Python 队列阻塞 get()时没反应

本文主要是介绍Python 队列阻塞 get()时没反应,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

当队列为空时,执行get(),不会报异常

会进入阻塞状态,直到队列中有东西可取为止

from queue import Queue

taskQueue = Queue()
taskQueue.put('queue task 1')

print(f'队列长度:{taskQueue.qsize()}')
print(f'取值:{taskQueue.get()}')
print(f'队列长度:{taskQueue.qsize()}')
print(f'取值:{taskQueue.get()}')  # 在这里阻塞

print('END')



block=False 未取得值时,不进入阻塞状态,抛出异常

from queue import Queue

try:
    taskQueue = Queue()
    taskQueue.put('queue task 1')

    print(f'队列长度:{taskQueue.qsize()}')
    print(f'取值:{taskQueue.get()}')
    print(f'队列长度:{taskQueue.qsize()}')
    print(f'取值:{taskQueue.get(block=False)}')  # 在这里抛出异常
except:
    pass

print('END')



timeout 超时未取得值时,抛出异常

import time
from queue import Queue
from threading import Thread

taskQueue = Queue()


# 5秒往队列中put一次
def queue_put():
    for i in range(1, 101):
        print('queue put')
        taskQueue.put(f'queue task {i}')
        time.sleep(5)


# timeout 超时时间内,未取得值,会抛出异常
def queue_get():
    while 1:
        print(f'取值:{taskQueue.get(timeout=3)}')


t1 = Thread(target=queue_put)
t1.start()

t2 = Thread(target=queue_get)
t2.start()

这篇关于Python 队列阻塞 get()时没反应的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!