mirror of
https://github.com/kennethreitz/background.git
synced 2026-06-05 06:56:14 +00:00
remove decorator decorator
Signed-off-by: Kenneth Reitz <me@kennethreitz.org>
This commit is contained in:
@@ -1,6 +1,3 @@
|
||||
[[source]]
|
||||
url = "https://pypi.python.org/simple"
|
||||
verify_ssl = true
|
||||
|
||||
[packages]
|
||||
decorator = "*"
|
||||
|
||||
+8
-8
@@ -3,8 +3,6 @@
|
||||
import multiprocessing
|
||||
import concurrent.futures
|
||||
|
||||
from decorator import decorator
|
||||
|
||||
def default_n():
|
||||
return multiprocessing.cpu_count()
|
||||
|
||||
@@ -23,15 +21,17 @@ def run(f, *args, **kwargs):
|
||||
|
||||
return f
|
||||
|
||||
@decorator
|
||||
|
||||
def task(f, *args, **kwargs):
|
||||
result = run(f, *args, **kwargs)
|
||||
results.append(result)
|
||||
def do_task():
|
||||
result = run(f, *args, **kwargs)
|
||||
results.append(result)
|
||||
|
||||
for cb in callbacks:
|
||||
result.add_done_callback(cb)
|
||||
for cb in callbacks:
|
||||
result.add_done_callback(cb)
|
||||
|
||||
return result
|
||||
return result
|
||||
return do_task
|
||||
|
||||
def callback(f):
|
||||
callbacks.append(f)
|
||||
|
||||
Reference in New Issue
Block a user