简单的任务管理
taskin的Python项目详细描述
taskin提供简单的任务管理。任务是简单的可调用的 它将使用一个资源池执行。游泳池可以是 进程或线程池以实现所需的 同意。这套任务称为流定义了流 通过定义要运行的函数列表。
下面是一个示例：
import subprocess
from pprint import pprint
from taskin import IfTask, MapTask, do_flow
def foo(data):
return 1
def check(v):
return v == 1
def bar(data):
return 'bar'
def baz(data):
return 'baz'
def finish(data):
result = {}
for i in data:
zone, ips = i
result[zone] = ips
return result
def dig_it(zone):
cmd = 'dig +short %s' % zone
print('running: %s' % cmd.strip())
ips = subprocess.check_output(cmd.split()).strip().split('\n')
return (zone, ips)
myflow = [
foo,
IfTask(
check,
[bar],
[baz]
),
MapTask(dig_it, [
'ionrock.org',
'google.com',
'yahoo.com',
]),
finish,
]
def main():
results = do_flow(myflow, {})
pprint(results)
print('Done')
if __name__ == '__main__':
main()
- 免费软件：BSD许可证
- 文档：https://taskin.readthedocs.org。
欢迎加入QQ群-->： 979659372
