How can I kill all threads?

Question

In this script:

import threading, socket class send(threading.Thread): def run(self): try: while True: try: s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.connect((url,port)) s.send(b"Hello world!") print ("Request Sent!") except: s.close() except KeyboardInterrupt: # here i'd like to kill all threads if possible for x in range(800): send().start()

Is it possible to kill all threads in the except of KeyboardInterrupt? I've searched on the net and yeah, I know that it has been already asked, but I'm really new in python and I didn't get so well the method of these other question asked on stack.

You want to kill all threads... does this include the main thread and as a consequence, the application? If so, simply make all your threads daemons and then when you want to quit, use sys.exit(). — CristiFati
– CristiFati, Commented Sep 8, 2016 at 0:32
@CristiFati: That won't help if the KeyboardInterrupt is delivered to one of the threads (the thread that receives it is basically random IIRC). Thus the need for alerting the main thread so it can exit at the appropriate time. — ShadowRanger
– ShadowRanger, Commented Sep 8, 2016 at 0:34
Right @ShadowRanger, thank you for pointing it out, threads tend to swallow exceptions. As a note, when I'm dealing with threads, I use the reverse approach: in a thread's loop, if a key was pressed (the logic can be expanded based on key), end it. — CristiFati
– CristiFati, Commented Sep 8, 2016 at 0:45
No way ! Socket is external thread. Set a timeout value for auto kill. How to handle *socket.error? while True is bad idea, while some_status_bolean better ! — dsgdfg
– dsgdfg, Commented Sep 8, 2016 at 7:56

ShadowRanger · Accepted Answer · 2016-09-08 00:31:17Z

4

No. Individual threads can't be terminated forcibly (it's unsafe, since it could leave locks held, leading to deadlocks, among other things).

Two ways to do something like this would be to either:

Have all threads launched as daemon threads, with the main thread waiting on an Event/Condition and exiting as soon as one of the threads sets the Event or notifies the Condition. The process terminates as soon as the (sole) non-daemon thread exits, ending all the daemon threads
Use a shared Event that all the threads poll intermittently, so they cooperatively exit shortly after it is set.

answered Sep 8, 2016 at 0:31

ShadowRanger

158k12 gold badges221 silver badges315 bronze badges

Sign up to request clarification or add additional context in comments.

4 Comments

Allexj Over a year ago

thanks for answer. I've seen the 2 way here: stackoverflow.com/questions/323972/… but I really don't know how to implement it to my send() class.

Allexj Over a year ago

I'm running on Linux

Allexj Over a year ago

so? anyone can help me or it's impossible to add a killing thread in keybord interrupt?

ShadowRanger Over a year ago

@allexj: You can't kill threads, like I already said. Use a shared Event, change while True: to while not myevent.is_set():, and stop using a bare except inside the loop (it will catch KeyboardInterrupt preventing you from processing it; catch Exception or the like). Then when you catch KeyboardInterrupt, call myevent.set() to tell all the other threads to stop processing on their next loop. This is not that hard to adapt, try playing around with it if it doesn't work immediately.

WarnerStark · Accepted Answer · 2022-11-11 15:05:05Z

As a comment said, use exit(n) to terminate a threads, but it might not terminate all threads necessarily and threads will mostly continue to run.

So your approach is to use os._exit(n), This terminates all threads and does what you want.

But be warned os._exit is not a good way to exit a script, and should be used only in special cases.

Bhavesh Achhada · Accepted Answer · 2022-11-11 15:24:11Z

@Allexj: You got an accurate answer from @ShadowRanger. You can do it as shown below.

import threading, socket, sys event = Threading.Event() # define an Event class send(threading.Thread): def run(self): try: global event while True: try: s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.connect((url,port)) s.send(b"Hello world!") print ("Request Sent!") except: s.close() except KeyboardInterrupt: # here i'd like to kill all threads if possible event.set() # set the event as soon as any thread receives an keyboardInterrupt. try: for x in range(800): send(daemon=True).start() event.wait() except KeyboardInterrupt: # If user pressed ctrl+c while loop was still running, then this will be useful pass sys.exit(0)

Collectives™ on Stack Overflow

How can I kill all threads?

3 Answers 3

4 Comments

Comments

Comments

Linked

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

4 Comments

Comments

Comments

Linked

Related