python異步任務隊列示例
更新時間：2014年04月01日 14:42:36 作者：
這篇文章主要介紹了python異步任務隊列示例,需要的朋友可以參考下
很多場景為了不阻塞，都需要異步回調機制。這是一個簡單的例子，大家參考使用吧
復制代碼 代碼如下:
#!/usr/bin/env python
# -*- coding: UTF-8 -*-
import logging
import queue
import threading
def func_a(a, b):
return a + b
def func_b():
pass
def func_c(a, b, c):
return a, b, c
# 異步任務隊列
_task_queue = queue.Queue()
def async_call(function, callback, *args, **kwargs):
_task_queue.put({
'function': function,
'callback': callback,
'args': args,
'kwargs': kwargs
})
def _task_queue_consumer():
"""
異步任務隊列消費者
"""
while True:
try:
task = _task_queue.get()
function = task.get('function')
callback = task.get('callback')
args = task.get('args')
kwargs = task.get('kwargs')
try:
if callback:
callback(function(*args, **kwargs))
except Exception as ex:
if callback:
callback(ex)
finally:
_task_queue.task_done()
except Exception as ex:
logging.warning(ex)
def handle_result(result):
print(type(result), result)
if __name__ == '__main__':
t = threading.Thread(target=_task_queue_consumer)
t.daemon = True
t.start()
async_call(func_a, handle_result, 1, 2)
async_call(func_b, handle_result)
async_call(func_c, handle_result, 1, 2, 3)
async_call(func_c, handle_result, 1, 2, 3, 4)
_task_queue.join()
相關文章
這篇文章主要介紹了pandas之query方法和sample隨機抽樣操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-03-03
用?Python?腳本實現(xiàn)電腦喚醒后自動拍照并截屏發(fā)郵件通知
這篇文章主要介紹了用?Python?腳本實現(xiàn)電腦喚醒后自動拍照并截屏發(fā)郵件通知，文中詳細的介紹了代碼示例，具有一定的 參考價值，感興趣的可以了解一下2023-03-03
大家好，本篇文章主要講的是如何用python批量發(fā)送工資條郵件，感興趣的同學趕快來看一看吧，對你有幫助的話記得收藏一下2022-01-01
這篇文章主要介紹了Python運算符重載用法,實例分析了幾種常見的Python運算符重載的使用技巧,需要的朋友可以參考下2015-06-06
這篇文章主要介紹了python中內置類型添加屬性問題詳解，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值，需要的小伙伴可以參考一下2022-09-09
為了實現(xiàn)可維護性,我們的Python函數(shù)應該：小型、只做一項任務；沒有重復；有一個層次的抽象性；有一個描述性的名字和有少于四個參數(shù),下面我們就來看看這6個特性的實踐吧2023-08-08
graphviz是貝爾實驗室開發(fā)的一個開源的工具包，它使用一個特定的DSL(領域特定語言):dot作為腳本語言，然后使用布局引擎來解析此腳本，并完成自動布局，這篇文章主要介紹了如何在anaconda中配置graphviz包,需要的朋友可以參考下2023-02-02
Python使用Selenium時遇到網(wǎng)頁＜body＞劃不動的問題解決方法
如果在使用 Selenium 時遇到網(wǎng)頁的 <body> 劃不動的問題,這通常是因為頁面的滾動機制（例如,可能使用了一個具有固定高度的容器或自定義的滾動條）導致無法通過簡單的 JavaScript 實現(xiàn)滾動,可以通過以下方法來解決該問題2024-10-10
這篇文章主要介紹了Python中的元類編程入門指引,來自于IBM官方網(wǎng)站技術文檔,需要的朋友可以參考下2015-04-04
這篇文章主要介紹了python 如何將IP 地址轉整數(shù)，幫助大家了解轉換的原理與收益，更好的理解python，感興趣的朋友可以了解下2020-11-11