溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要介紹了python多線程中消息隊列怎么實現，具有一定借鑒價值，需要的朋友可以參考下。希望大家閱讀完這篇文章后大有收獲。下面讓小編帶著大家一起了解一下。
線程間通信：消息隊列
主要方式：
通過變量，直接讀寫；通過消息隊列；
消息隊列：
from queue import Queue
Queue與多進程中的類似，主要方法：
方法說明：
給大家演示實例：
import threading
from queue import Queue
#消息隊列
msgq = Queue()
def recvmsg(*args, **kwargs):
#線程函數，接受消息
while True:
msg = msgq.get()
print('rev msg:', msg)
if msg == 'q':
break
def sendmsg():
#發送消息
while True:
msg = input('enter:')
msgq.put(msg)
if msg == 'q':
break
if __name__ == '__main__':
#創建線程
t1 = threading.Thread(target=recvmsg)
t1.start()
sendmsg()
t1.join()結果：
enter:1 rev msg: 1 enter:2 rev msg: 2 enter:3 rev msg: 3 enter:q rev msg: q
感謝你能夠認真閱讀完這篇文章，希望小編分享python多線程中消息隊列怎么實現內容對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，遇到問題就找億速云，詳細的解決方法等著你來學習!
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
