使用joinablequeue的生產者和消費者模型

2021-09-13 04:14:06 字數 932 閱讀 6630

import multiprocessing

import queue

import time

def consumer(output_q):

print("time is ".format(time.ctime()))

while true:

item = output_q.get()

print("pull" , item , "out of q")

output_q.task_done() #發出訊號通知完成任務

print("out of consumer ".format(time.ctime()))

def produce(sequeue, input_q):

print("input producer " + time.ctime())

for item in sequeue: #將sequeue的內容放入q倉庫中

input_q.put(item)

print("make", item, "into q")

print("in put producer " + time.ctime())

if __name__ == "__main__":

q = multiprocessing.joinablequeue()

#執行消費者程序

cons_p = multiprocessing.process(target=consumer, args=(q,))

cons_p.daemon = true

cons_p.start()

#生產多個項,sequeue代表要傳送給生產者的項

sequeue = [1, 2, 3, 4, 5]

produce(sequeue, q)

#等待所有項被處理

q.join()

使用GraphEdit使用

1 註冊元件。其實乙個filter就是乙個com元件,所以使用之前需要註冊,可以有兩種方法對元件進行註冊。1.直接使用命令。命令列下輸入 regsvr32 hqtlystd.ax 編譯之後你會在工程目錄下的debug中找到hqtlystd.ax,這個就是要用的filter 即可註冊成功。2.vc6....

MySQL使用學習使用 mysql學習使用

1 mysql學習 1 安裝 ubuntu下直接安裝 apt get install mysql server 2 檢查伺服器是否啟動 sudo netstat tap grep mysql,如果啟動成功,出現以下資訊 tcp00localhost.localdomain mysql listen ...

學習使用CSDN markdown使用

建立乙個自定義列表 如何建立乙個註腳 注釋也是必不可少的 katex數學公式 新的甘特圖功能,豐富你的文章 uml 圖表 flowchart流程圖 匯出與匯入 你好!這是你第一次使用markdown編輯器所展示的歡迎頁。如果你想學習如何使用markdown編輯器,可以仔細閱讀這篇文章,了解一下mar...