# Start the server thread and wait for it to be listening.
thread = threading.Thread(target=server)
- thread.setDaemon(True)
+ thread.daemon = True
thread.start()
addr = q.get()
"""
self._thread = t = threading.Thread(target=self.serve_forever,
args=(self.poll_interval,))
- t.setDaemon(True)
+ t.daemon = True
t.start()
def serve_forever(self, poll_interval):
"""
self._thread = t = threading.Thread(target=self.serve_forever,
args=(self.poll_interval,))
- t.setDaemon(True)
+ t.daemon = True
t.start()
def serve_forever(self, poll_interval):
self.sock.settimeout(60) # Safety net. Look issue 11812
self.port = socket_helper.bind_port(self.sock)
self.thread = threading.Thread(target=server, args=(self.evt,self.sock))
- self.thread.setDaemon(True)
+ self.thread.daemon = True
self.thread.start()
self.evt.wait()
for i in range(nthreads):
threads.append(threading.Thread(target=run))
for t in threads:
- t.setDaemon(True)
+ t.daemon = True
t.start()
# We don't want measurements to include thread startup overhead,
# so we arrange for timing to start after all threads are ready.
for i in range(nthreads):
threads.append(threading.Thread(target=run))
for t in threads:
- t.setDaemon(True)
+ t.daemon = True
t.start()
# Wait for threads to be ready
with ready_cond:
for i in range(nthreads):
threads.append(threading.Thread(target=run))
for t in threads:
- t.setDaemon(True)
+ t.daemon = True
t.start()
# Wait for threads to be ready
with ready_cond: