gh-155334: Add start parameter to threading.Thread

Use start=True in the stdlib.

Author: vstinner

Doc/library/threading.rst

@@ -510,7 +510,7 @@ since it is impossible to detect the termination of alien threads.
 
 
 .. class:: Thread(group=None, target=None, name=None, args=(), kwargs={}, *, \
-                  daemon=None, context=None)
+                  daemon=None, context=None, start=False)
 
    This constructor should always be called with keyword arguments.  Arguments
    are:
@@ -545,6 +545,8 @@ since it is impossible to detect the termination of alien threads.
    current context, pass the value from :func:`~contextvars.copy_context`. The
    flag defaults true on free-threaded builds and false otherwise.
 
+   If *start* is true, start immediately the thread after initialization.
+
    If the subclass overrides the constructor, it must make sure to invoke the
    base class constructor (``Thread.__init__()``) before doing anything else to
    the thread.
@@ -558,6 +560,9 @@ since it is impossible to detect the termination of alien threads.
    .. versionchanged:: 3.14
       Added the *context* parameter.
 
+   .. versionchanged:: next
+      Added the *start* parameter.
+
    .. method:: start()
 
       Start the thread's activity.

Doc/whatsnew/3.16.rst

@@ -461,6 +461,13 @@ symtable
   (Contributed by Serhiy Storchaka in :gh:`153844`.)
 
 
+threading
+---------
+
+* Add *start* parameter to :class:`threading.Thread` to start immediately the
+  thread after initialization
+  (Contributed by Victor Stinner in :gh:`155334`.)
+
 tkinter
 -------
 

Lib/concurrent/futures/thread.py

@@ -233,8 +233,8 @@ def weakref_cb(_, q=self._work_queue):
             t = threading.Thread(name=thread_name, target=_worker,
                                  args=(weakref.ref(self, weakref_cb),
                                        self._create_worker_context(),
-                                       self._work_queue))
-            t.start()
+                                       self._work_queue),
+                                 start=True)
             self._threads.add(t)
             _threads_queues[t] = self._work_queue
 

Lib/concurrent/interpreters/__init__.py

@@ -242,6 +242,6 @@ def call_in_thread(self, callable, /, *args, **kwargs):
 
         The return value and any raised exception are discarded.
         """
-        t = threading.Thread(target=self._call, args=(callable, args, kwargs))
-        t.start()
-        return t
+        return threading.Thread(target=self._call,
+                                args=(callable, args, kwargs),
+                                start=True)

Lib/idlelib/pyshell.py

@@ -543,7 +543,7 @@ def __request_interrupt(self):
         self.rpcclt.remotecall("exec", "interrupt_the_server", (), {})
 
     def interrupt_subprocess(self):
-        threading.Thread(target=self.__request_interrupt).start()
+        threading.Thread(target=self.__request_interrupt, start=True)
 
     def kill_subprocess(self):
         if self._afterid is not None:

Lib/idlelib/run.py

@@ -158,7 +158,7 @@ def main(del_exitfunc=False):
                      name='SockThread',
                      args=((LOCALHOST, port),),
                      daemon=True,
-                    ).start()
+                     start=True)
 
     while True:
         try:

Lib/multiprocessing/managers.py

@@ -172,9 +172,8 @@ def serve_forever(self):
         self.stop_event = threading.Event()
         process.current_process()._manager_server = self
         try:
-            accepter = threading.Thread(target=self.accepter)
-            accepter.daemon = True
-            accepter.start()
+            accepter = threading.Thread(target=self.accepter,
+                                        daemon=True, start=True)
             try:
                 while not self.stop_event.is_set():
                     self.stop_event.wait(1)
@@ -193,9 +192,8 @@ def accepter(self):
                 c = self.listener.accept()
             except OSError:
                 continue
-            t = threading.Thread(target=self.handle_request, args=(c,))
-            t.daemon = True
-            t.start()
+            threading.Thread(target=self.handle_request, args=(c,),
+                             daemon=True, start=True)
 
     def _handle_request(self, c):
         request = None

Lib/multiprocessing/resource_sharer.py

@@ -125,9 +125,7 @@ def _start(self):
         util.debug('starting listener and thread for sending handles')
         self._listener = Listener(authkey=process.current_process().authkey, backlog=128)
         self._address = self._listener.address
-        t = threading.Thread(target=self._serve)
-        t.daemon = True
-        t.start()
+        t = threading.Thread(target=self._serve, daemon=True, start=True)
         self._thread = t
 
     def _serve(self):

Lib/profiling/sampling/_child_monitor.py

@@ -88,8 +88,8 @@ def __enter__(self):
             target=self._monitor_loop,
             daemon=True,
             name=f"child-monitor-{self.parent_pid}",
+            start=True,
         )
-        self._monitor_thread.start()
         return self
 
     def __exit__(self, exc_type, exc_val, exc_tb):

Lib/profiling/sampling/gecko_collector.py

@@ -749,8 +749,7 @@ def spin():
             sys.stderr.write('\r' + ' ' * (len(message) + 3) + '\r')
             sys.stderr.flush()
 
-        spinner_thread = threading.Thread(target=spin, daemon=True)
-        spinner_thread.start()
+        spinner_thread = threading.Thread(target=spin, daemon=True, start=True)
 
         temp_path = None
         replaced = False