«

Hi all,

How can I get a raised exception from other thread that is in an
imported module?

For example:

---------------
programA.py
---------------

import programB

thread = programB.MakeThread()
thread.start()

---------------
programB.py
---------------
import threading, time

class SomeException(Exception):
pass

class MakeThread(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)

def run(self):
i = 0
while 1:
print i
i += 1
time.sleep(1) #wait a second to continue
if i>10:
raise SomeException()


Thanks

Daniel

On non-Windows system there are a ton of ways to do it--this is almost a
whole field unto itself. (D-BUS, fifos, sockets, shmfs, etc.) In
Windows, I wouldn't have a clue.

I guess this is a hard question to answer without a bit more
information.

On Fri, 2005-10-14 at 14:45 -0700, dcrespo wrote:
> Hi all,
>
> How can I get a raised exception from other thread that is in an
> imported module?
>
> For example:
>
> ---------------
> programA.py
> ---------------
>
> import programB
>
> thread = programB.MakeThread()
> thread.start()
>
> ---------------
> programB.py
> ---------------
> import threading, time
>
> class SomeException(Exception):
> pass
>
> class MakeThread(threading.Thread):
> def __init__(self):
> threading.Thread.__init__(self)
>
> def run(self):
> i = 0
> while 1:
> print i
> i += 1
> time.sleep(1) #wait a second to continue
> if i>10:
> raise SomeException()
>
>
> Thanks
>
> Daniel
>

Thanks for your answer, but I think that created thread in python
should create a thread either on windows and linux.

Can you give me Python example of how to do what I want to do? Thanks

dcrespo wrote:
> How can I get a raised exception from other thread that is in an
> imported module?

Define what "get" means for your purposes. It appears that you mean you
want to catch the exception, but in the thread which launched the other
thread in the first place. If that's true, please show where you would
expect to catch this exception, given that when you start the thread,
the main thread continues running and might even finish before the other
thread finishes.

> thread = programB.MakeThread()
> thread.start()
....
# later code which might have completed by the time the thread finishes
....

Are you looking, for example, for some kind of
thread.waitUntilCompletionAndReRaiseExceptions() method?

-Peter

I also need an answer to this problem. I'm using windows. Throwing an
exception in thread B from thread A using a callback function.

The function runs, but the thread never actually catches the exception.
The try/except block is in the run() method (over-riden from the
Thread class)

wrote:
> I also need an answer to this problem.

What _is_ the problem? We're still waiting for a clear description from
the OP as to what the problem really is. How would you describe what
_your_ problem is?

> I'm using windows. Throwing an
> exception in thread B from thread A using a callback function.
>
> The function runs, but the thread never actually catches the exception.
> The try/except block is in the run() method (over-riden from the
> Thread class)

Rather than force us all to guess what you are doing wrong, maybe it
would be better if you posted a small amount of code that shows the problem.

Exceptions raised in threads can definitely be caught in the run()
method if the code is written correctly, so that is not in itself an issue.

-Peter

Here's a dumbed down version of what i'm doing:

import time
import threading

class threader(threading.Thread):
def __init__(self):
threading.Thread.__init__(self)
pass

def run(self):
try:
while 1:
time.sleep(5)
except SystemExit:
print "Got Exit Message in thread"

def killMe(self):
raise SystemExit



thread1 = threader()
thread2 = threader()

thread1.start()
thread2.start()

time.sleep(5)

try:
print "Killing thread 1"
thread1.killMe()
print "killing thread 2"
thread2.killMe()
except SystemExit:
print "Got exceptin in main thread"



The exception is not propogated to the threads I spawned, but instead
comes back in the main thread.

Nevermind. I found a better solution. I used shared memory to create
a keep-alive flag. I then use the select function with a specified
timeout, and recheck the keep-alive flag after each timeout.

Thanx for all the input.

On 15 Oct 2005 20:54:33 -0700, declaimed the
following in comp.lang.python:


> try:
> print "Killing thread 1"
> thread1.killMe()
> print "killing thread 2"
> thread2.killMe()
> except SystemExit:
> print "Got exceptin in main thread"
>
>
>
> The exception is not propogated to the threads I spawned, but instead
> comes back in the main thread.

No surprise there... The function invocation is being made in the
CONTEXT of the main thread...
--
> ================================================== ============ <
> | Wulfraed Dennis Lee Bieber KD6MOG <
> | Bestiaria Support Staff <
> ================================================== ============ <
> Home Page: <http://www.dm.net/~wulfraed/> <
> Overflow Page: <http://wlfraed.home.netcom.com/> <

In article < .com>,
wrote:

> Nevermind. I found a better solution. I used shared memory to create
> a keep-alive flag. I then use the select function with a specified
> timeout, and recheck the keep-alive flag after each timeout.
>
> Thanx for all the input.

How about a threading.Event?

-Mike