新非同步框架CXYX,快來吃螃蟹

cxyx 簡介

cxyx說明

還在使用celery麼?不妨嘗試下新框架cxyx,使用方式和celery相似哦,並且相容使用redis分布式集群.

建立消費者 task.py 並編輯如下

from cxyx import cxyx))

defmuti
(a, b)
:return a - b
defadd
(a, b)
:return a + b

from task import add, muti

add.verb(4,
5)# add task async.
res_obj = muti.verb(4,
5)result = res_obj.until_get_result(
)# block until get the result.

python product.py 啟動生產者

pip install cxyx

)def

chufa

(a):

return

4/ a

@chufa.before_do_task

defbefore

(*args,

**kwargs)

:print

("before "

, args, kwargs)

@chufa.after_do_task

defafter

(*args,

**kwargs)

:print

("after "

, args, kwargs)

@chufa.success_do_task

defsuccess

(a, final_result)

:print

("success "

, a, final_result)

@chufa.fail_do_task

deffail

(*args,

**kwargs)

:print

("fail "

, args, kwargs)

望文生義:

before_do_task 在任務執行之前處理的操作

after_do_task 在任務執行之後處理的操作

success_do_task在任務執行成功之後處理的操作

fail_do_task 在任務執行異常拋錯之後處理的操作

目前只支援redis和redis集群作中介軟體,後續還需維護,增加新的中介軟體.

cxyx框架github位址

覺得好可以幫忙點個 star 哦.

celery非同步框架

官方 celery 官網 celery 官方文件英文版 celery 官方文件中文版 celery的架構由三部分組成，訊息中介軟體 message broker 任務執行單元 worker 和 任務執行結果儲存 task result store 組成。訊息中介軟體 celery本身不提供訊息服務，...

非同步處理任務框架

非同步處理任務框架 非同步獲取頭像 第三個引數就是非同步任務執行完畢後的返回值 author administrator public class loadimageasyntask extends asynctask public inte ce loadimageasyntaskcallback...

在子執行緒中更新UI 延時更新（非同步訊息處理機制）

1.新增handler物件 public handler handler new handler 2.建立程序，程序中傳送message訊息給handler new thread new runnable catch interruptedexception e message message.ob...