aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSerhiy Storchaka <storchaka@gmail.com>2019-05-06 22:40:27 +0300
committerGitHub <noreply@github.com>2019-05-06 22:40:27 +0300
commitd53cf99dca4605ace4b81b1e585616b3e1b74fa6 (patch)
tree0cce690e90a722457d3f472f1a7c4e471182e2bc /Lib/concurrent
parentbpo-36793: Remove unneeded __str__ definitions. (GH-13081) (diff)
downloadcpython-d53cf99dca4605ace4b81b1e585616b3e1b74fa6.tar.gz
cpython-d53cf99dca4605ace4b81b1e585616b3e1b74fa6.tar.bz2
cpython-d53cf99dca4605ace4b81b1e585616b3e1b74fa6.zip
bpo-36542: Allow to overwrite the signature for Python functions. (GH-12705)
Diffstat (limited to 'Lib/concurrent')
-rw-r--r--Lib/concurrent/futures/_base.py1
-rw-r--r--Lib/concurrent/futures/process.py1
-rw-r--r--Lib/concurrent/futures/thread.py1
3 files changed, 3 insertions, 0 deletions
diff --git a/Lib/concurrent/futures/_base.py b/Lib/concurrent/futures/_base.py
index ea16eef841c..8f155f0ea82 100644
--- a/Lib/concurrent/futures/_base.py
+++ b/Lib/concurrent/futures/_base.py
@@ -567,6 +567,7 @@ class Executor(object):
'got %d' % (len(args)-1))
raise NotImplementedError()
+ submit.__text_signature__ = '($self, fn, /, *args, **kwargs)'
def map(self, fn, *iterables, timeout=None, chunksize=1):
"""Returns an iterator equivalent to map(fn, iter).
diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py
index e6ce278b5d4..21bf4a447f0 100644
--- a/Lib/concurrent/futures/process.py
+++ b/Lib/concurrent/futures/process.py
@@ -630,6 +630,7 @@ class ProcessPoolExecutor(_base.Executor):
self._start_queue_management_thread()
return f
+ submit.__text_signature__ = _base.Executor.submit.__text_signature__
submit.__doc__ = _base.Executor.submit.__doc__
def map(self, fn, *iterables, timeout=None, chunksize=1):
diff --git a/Lib/concurrent/futures/thread.py b/Lib/concurrent/futures/thread.py
index 0a61e3a9ac1..2af31a106dd 100644
--- a/Lib/concurrent/futures/thread.py
+++ b/Lib/concurrent/futures/thread.py
@@ -174,6 +174,7 @@ class ThreadPoolExecutor(_base.Executor):
self._work_queue.put(w)
self._adjust_thread_count()
return f
+ submit.__text_signature__ = _base.Executor.submit.__text_signature__
submit.__doc__ = _base.Executor.submit.__doc__
def _adjust_thread_count(self):