ó
|
R\¬Qc @ s d d l Z d d l m Z d d l m Z d d l Z d d l Z d d l Z e j j d Z
|
e j j d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d e f d YZ d e j f d
|
YZ d e j f d YZ d e f d YZ d e f d YZ d e f d YZ d e j f d YZ d e j f d YZ d e j f d YZ d e j f d YZ d e j f d YZ d e j f d YZ d e j! f d YZ! d! Z" e# d" k re" n d S(# iÿÿÿÿN( t verbose( t assert_python_okt threadt threading( t
|
lock_testst Counterc B s, e Z d Z d Z d Z d Z RS( c C s d | _ d S( Ni ( t value( t self( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt __init__ s c C s | j d 7_ d S( Ni ( R ( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt inc s c C s | j d 8_ d S( Ni ( R ( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt dec s c C s | j S( N( R ( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt get s ( t __name__t
|
__module__R R R
|
R ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR s t
|
TestThreadc B s e Z d Z d Z RS( c C s> t j j | d | | | _ | | _ | | _ | | _ d S( Nt name( R t ThreadR t testcaset semat mutext nrunning( R R R R R R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR s
|
c C s t j d } t r/ d | j | d f GHn | j â | j L | j j t rk | j j Gd GHn | j j | j j d k Wd QXt
|
j | t r¶ d G| j Gd GHn | j U | j j | j j | j j d k t rd | j | j j f GHn Wd QXWd QXd S(
|
Ng Ã@s task %s will run for %.1f usecg .As tasks are runningi t taskt donei s$ %s is finished. %d tasks are running( t randomR R R R R R R R t
|
assertTruet timet sleepR
|
( R t delay( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt run' s&
|
|
%
|
( R R R R ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR s t BaseTestCasec B s e Z d Z d Z RS( c C s t j j | _ d S( N( t testt test_supportt threading_setupt _threads( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt setUp@ s c C s$ t j j | j t j j d S( N( R R t threading_cleanupR! t reap_children( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt tearDownC s ( R R R" R% ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR ? s t ThreadTestsc B s e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
|
d Z d
|
Z d Z e j e e d d d Z RS( c C s_ d } t j d d } t j } t } g } xy t | D]k } t d | | | | | } | j | | j | j d | j
|
t j d t | | j q@ Wt r½ d GHn xw | D]o } | j | | j
|
| j | j | j d | j | j d k | j
|
t j d t | qÄ Wt rEd GHn | j | j d d S(
|
Ni
|
R i s <thread %d>s <TestThread\(.*, initial\)>s! waiting for all tasks to completei s <TestThread\(.*, \w+ -?\d+\)>s all tasks done( R t BoundedSemaphoret RLockR t rangeR t appendt assertEqualt identt NoneR t ret matcht reprt startR t joint is_alivet assertNotEqualt assertFalseR ( R t NUMTASKSR R t
|
numrunningt threadst it t( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_various_opsL s, #c s | j t j j d k f d } t j g t j | d j | j d d k t j d =d S( Nc s$ j t j j j d S( N( R* R t currentThreadR, t set( ( R R, ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt fn s i ( (
|
R5 R R< R, R- t EventR t start_new_threadt waitt _active( R R> ( ( R R, s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt" test_ident_of_no_threading_threadsk s
|
c C s` t r d GHn y t j d Wn# t j k
|
rD t r@ d GHn d SX| j t j d d S( Ns with 256kB thread stack size...i s4 platform does not support changing thread stack sizei ( R R t
|
stack_sizeR t errorR; ( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_various_ops_small_stackz s
|
c C s` t r d GHn y t j d Wn# t j k
|
rD t r@ d GHn d SX| j t j d d S( Ns with 1MB thread stack size...i s4 platform does not support changing thread stack sizei ( R R RD R RE R; ( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_various_ops_large_stack s
|
c C sy d } t j } | j t j | | f } | j | j | t j | j t j | t j t j | =d S( Nc S s t j | j d S( N( R t current_threadt release( R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR> s
|
( R t Lockt acquireR R@ t assertInRB t assertIsInstancet _DummyThread( R R> R t tid( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_foreign_thread s
|
|
c sT y d d l } Wn t k
|
r2 t r. d GHn d SX| j j } d t f d Y | j } t j } y) | | j | | } x
|
t
|
r q WWn k
|
r¬ n X| j d y | j | d Wn t k
|
rá n Xt j t j d t j f f d Y} | } t
|
| _ | j t rId GHn t rWd
|
GHn | | j d | } | j | d t rd GHn j } | j | t r´d GHn | j | j t rÓd GHn | | j | j | } | j | d t r d GHn j d d | j | j t r:d GHn | j rP| j n d S( Niÿÿÿÿs2 test_PyThreadState_SetAsyncExc can't import ctypest AsyncExcc B s e Z RS( ( R R ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRQ ° s s AsyncExc not raisedi t Workerc s e Z f d Z RS( c sk t j | _ t | _ y( x! t r> j t j d q WWn$ k
|
rf t | _ j n Xd S( Ng¹?( R t get_identt idt Falset finishedt TrueR= R R ( R ( RQ t worker_saw_exceptiont worker_started( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR Ò s
|
( R R R ( ( RQ RX RY ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRR Ñ s s started worker threads trying nonsensical thread idi s, waiting for worker thread to get starteds" verifying worker hasn't exiteds2 attempting to raise asynch exception in workers5 waiting for worker to say it caught the exceptiont timeouti
|
s all OK -- joining worker( t ctypest ImportErrorR t pythonapit PyThreadState_SetAsyncExct Exceptiont py_objectR RS t c_longRW t failR+ t UnboundLocalErrorR R? R t daemonR1 RA R RV RT R2 ( R R[ t set_async_exct exceptionRO t resultRR R: t ret( ( RQ RX RY s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_PyThreadState_SetAsyncExc¦ sh %
|
c C st d } t j } | t _ zH t j d d } | j t j | j | j | t j k d Wd | t _ Xd S( Nc W s t j d S( N( R RE ( t args( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt fail_new_thread s t targetc S s d S( N( R- ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt <lambda> s s: Failed to cleanup _limbo map on failure of Thread.start().( R t _start_new_threadR t assertRaisesR RE R1 R5 t _limbo( R Rk Rn R: ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_limbo_cleanup s c C sb y d d l } Wn t k
|
r2 t r. d GHn d SXt j t j d d g } | j | d d S( Niÿÿÿÿs6 test_finalize_with_runnning_thread can't import ctypess -csK if 1:
|
import ctypes, sys, time, thread
|
|
# This lock is used as a simple event variable.
|
ready = thread.allocate_lock()
|
ready.acquire()
|
|
# Module globals are cleared before __del__ is run
|
# So we save the functions in class dict
|
class C:
|
ensure = ctypes.pythonapi.PyGILState_Ensure
|
release = ctypes.pythonapi.PyGILState_Release
|
def __del__(self):
|
state = self.ensure()
|
self.release(state)
|
|
def waitingThread():
|
x = C()
|
ready.release()
|
time.sleep(100)
|
|
thread.start_new_thread(waitingThread, ())
|
ready.acquire() # Be sure the other thread is waiting.
|
sys.exit(42)
|
i* ( R[ R\ R t
|
subprocesst callt syst
|
executableR+ ( R R[ t rc( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_finalize_runnning_thread s c C s¨ t j t j d d g d t j d t j } | j | j j | j | j j | j \ } } | j
|
} | j | d k d | j | d k d t | d S( Ns -csO if 1:
|
import sys, threading
|
|
# A deadlock-killer, to prevent the
|
# testsuite to hang forever
|
def killer():
|
import os, time
|
time.sleep(2)
|
print 'program blocked; aborting'
|
os._exit(2)
|
t = threading.Thread(target=killer)
|
t.daemon = True
|
t.start()
|
|
# This is the trace function
|
def func(frame, event, arg):
|
threading.current_thread()
|
return func
|
|
sys.settrace(func)
|
t stdoutt stderri s interpreted was blockedi s Unexpected error: ( Rr t PopenRt Ru t PIPEt
|
addCleanupRx t closeRy t communicatet
|
returncodeR5 R R0 ( R t pRx Ry Rv ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_finalize_with_trace5 s c C s° t j t j d d g d t j d t j } | j | j j | j | j j | j \ } } | j
|
| j d t j d d | t j j } | j
|
| d d S( Ns -cs¦ if 1:
|
import threading
|
from time import sleep
|
|
def child():
|
sleep(1)
|
# As a non-daemon thread we SHOULD wake up and nothing
|
# should be torn down yet
|
print "Woke up, sleep function is:", sleep
|
|
threading.Thread(target=child).start()
|
raise SystemExit
|
Rx Ry s5 Woke up, sleep function is: <built-in function sleep>s ^\[\d+ refs\]t ( Rr Rz Rt Ru R{ R| Rx R} Ry R~ R+ t stripR. t subt MULTILINE( R R Rx Ry ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_join_nondaemon_on_shutdownW s !c C s¨ t j } t j } z~ xw t d d D]f } t j | d t j d d } | j | j | } | j | | d | | f q( WWd t j | Xd S( Ni id i Rl c S s d S( N( R- ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRm { s s& #1703448 triggered after %d trials: %s(
|
R t enumerateRt t getcheckintervalt xranget setcheckintervalR R1 R2 t assertNotIn( R t enumt old_intervalR9 R: t l( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_enumerate_after_joinq s
|
|
c C sÈ d t f d Y} | d t } t j | } | j j ~ | j d | d d t j | | d t
|
} t j | } | j j ~ | j d | d d t j | d S( Nt RunSelfFunctionc B s e Z d Z d Z RS( c S sH | | _ t j d | j d | f d i | d 6 | _ | j j d S( NRl Rj t kwargst yet_another( t should_raiseR R t _runR R1 ( R R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR s
|
c S s | j r t n d S( N( R t
|
SystemExit( R t other_refR ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR s ( R R R R ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR
s R t msgs %d references still around( t objectRU t weakreft refR R2 R+ R- Rt t getrefcountRW ( R R t cyclic_objectt weak_cyclic_objectt raising_cyclic_objectt weak_raising_cyclic_object( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_no_refcycle_through_target s t forks test needs fork()c C sB d } t d | \ } } } | j | d | j | d d S( Ns if 1:
|
import thread, threading, os, time
|
|
def background_thread(evt):
|
# Creates and registers the _DummyThread instance
|
threading.current_thread()
|
evt.set()
|
time.sleep(10)
|
|
evt = threading.Event()
|
thread.start_new_thread(background_thread, (evt,))
|
evt.wait()
|
assert threading.active_count() == 2, threading.active_count()
|
if os.fork() == 0:
|
assert threading.active_count() == 1, threading.active_count()
|
os._exit(0)
|
else:
|
os.wait()
|
s -cR ( R R+ ( R t codet _t outt err( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_dummy_thread_after_fork£ s ( R R R; RC RF RG RP Ri Rq Rw R R R R t unittestt
|
skipUnlesst hasattrt osR¦ ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR& H s Z & " t ThreadJoinOnShutdownc B sd e Z d Z d Z d Z e j e e d d e j e
|
j e k d d
|
Z e j e e d d e j e
|
j e k d d Z d Z e j e e d d e j e
|
j e k d d Z e j e e d d e j e
|
j e k d d Z e j e e d d e j e
|
j e k d d Z RS( t freebsd4t freebsd5t freebsd6t netbsd5t os2emxc C s¢ d | } t j t j d | g d t j } | j } | j j j d d } | j j | j
|
| d | j | d k d | j | d k d
|
d S( Nsó if 1:
|
import sys, os, time, threading
|
|
# a thread, which waits for the main program to terminate
|
def joiningfunc(mainthread):
|
mainthread.join()
|
print 'end of thread'
|
|
s -cRx s R s end of main
|
end of thread
|
i s interpreter was blockedi s Unexpected error( Rr Rz Rt Ru R{ RA Rx t readt replaceR} R+ R5 R ( R t scriptR Rv t data( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt _run_and_joinÈ s
|
$ c C s d } | j | d S( Nsô if 1:
|
import os
|
t = threading.Thread(target=joiningfunc,
|
args=(threading.current_thread(),))
|
t.start()
|
time.sleep(0.1)
|
print 'end of main'
|
( Rµ ( R R³ ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_1_join_on_shutdownÚ s R¡ s needs os.fork()s due to known OS bugc C s d } | j | d S( NsF if 1:
|
childpid = os.fork()
|
if childpid != 0:
|
os.waitpid(childpid, 0)
|
sys.exit(0)
|
|
t = threading.Thread(target=joiningfunc,
|
args=(threading.current_thread(),))
|
t.start()
|
print 'end of main'
|
( Rµ ( R R³ ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_2_join_in_forked_processç s c C s d } | j | d S( Ns9 if 1:
|
main_thread = threading.current_thread()
|
def worker():
|
childpid = os.fork()
|
if childpid != 0:
|
os.waitpid(childpid, 0)
|
sys.exit(0)
|
|
t = threading.Thread(target=joiningfunc,
|
args=(main_thread,))
|
print 'end of main'
|
t.start()
|
t.join() # Should not block: main_thread is already stopped
|
|
w = threading.Thread(target=worker)
|
w.start()
|
( Rµ ( R R³ ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt! test_3_join_in_forked_from_threadø s c C sx t j t j d | g d t j } | j } | j j j j d d } | j
|
| d d | j
|
| | d S( Ns -cRx s R i s Unexpected error( Rr Rz Rt Ru R{ RA Rx R± t decodeR² R+ ( R R³ t expected_outputR Rv R´ ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt assertScriptHasOutput s !c C s d } | j | d d S( NsD if 1:
|
import os, time, threading
|
|
finish_join = False
|
start_fork = False
|
|
def worker():
|
# Wait until this thread's lock is acquired before forking to
|
# create the deadlock.
|
global finish_join
|
while not start_fork:
|
time.sleep(0.01)
|
# LOCK HELD: Main thread holds lock across this call.
|
childpid = os.fork()
|
finish_join = True
|
if childpid != 0:
|
# Parent process just waits for child.
|
os.waitpid(childpid, 0)
|
# Child process should just return.
|
|
w = threading.Thread(target=worker)
|
|
# Stub out the private condition variable's lock acquire method.
|
# This acquires the lock and then waits until the child has forked
|
# before returning, which will release the lock soon after. If
|
# someone else tries to fix this test case by acquiring this lock
|
# before forking instead of resetting it, the test case will
|
# deadlock when it shouldn't.
|
condition = w._block
|
orig_acquire = condition.acquire
|
call_count_lock = threading.Lock()
|
call_count = 0
|
def my_acquire():
|
global call_count
|
global start_fork
|
orig_acquire() # LOCK ACQUIRED HERE
|
start_fork = True
|
if call_count == 0:
|
while not finish_join:
|
time.sleep(0.01) # WORKER THREAD FORKS HERE
|
with call_count_lock:
|
call_count += 1
|
condition.acquire = my_acquire
|
|
w.start()
|
w.join()
|
print('end of main')
|
s end of main
|
( R» ( R R³ ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt+ test_4_joining_across_fork_in_worker_thread s Fc C s d } d } | j | | d S( Ns if True:
|
import os, time, threading
|
|
start_fork = False
|
|
def worker():
|
# Wait until the main thread has attempted to join this thread
|
# before continuing.
|
while not start_fork:
|
time.sleep(0.01)
|
childpid = os.fork()
|
if childpid != 0:
|
# Parent process just waits for child.
|
(cpid, rc) = os.waitpid(childpid, 0)
|
assert cpid == childpid
|
assert rc == 0
|
print('end of worker thread')
|
else:
|
# Child process should just return.
|
pass
|
|
w = threading.Thread(target=worker)
|
|
# Stub out the private condition variable's _release_save method.
|
# This releases the condition's lock and flips the global that
|
# causes the worker to fork. At this point, the problematic waiter
|
# lock has been acquired once by the waiter and has been put onto
|
# the waiters list.
|
condition = w._block
|
orig_release_save = condition._release_save
|
def my_release_save():
|
global start_fork
|
orig_release_save()
|
# Waiter lock held here, condition lock released.
|
start_fork = True
|
condition._release_save = my_release_save
|
|
w.start()
|
w.join()
|
print('end of main thread')
|
s( end of worker thread
|
end of main thread
|
( R» ( R R³ t output( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt( test_5_clear_waiter_locks_to_avoid_crasha s 6c C sn d } g } x= t d D]/ } t j d | } | j | | j q Wx | D] } | j qV Wd S( Nc S s< t j } | d k r+ t j | d n t j d d S( Ni ( Rª R¡ t waitpidt _exit( t pid( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt do_fork_and_wait¡ s i Rl ( R) R R R* R1 R2 ( R RÂ R8 R9 R: ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_reinit_tls_after_fork s ( R¬ R R® R¯ s os2emx( R R t platforms_to_skipRµ R¶ R§ R¨ R© Rª t skipIfRt t platformR· R¸ R» R¼ R¾ RÃ ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyR« ¿ s '' 'H'9t ThreadingExceptionTestsc B s, e Z d Z d Z d Z d Z RS( c C s- t j } | j | j t | j d S( N( R R R1 Ro t RuntimeError( R R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_start_thread_again· s
|
c C s# t j } | j t | j d S( N( R RH Ro RÈ R2 ( R RH ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_joining_current_thread¼ s c C s# t j } | j t | j d S( N( R R Ro RÈ R2 ( R R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_joining_inactive_threadÀ s c C s3 t j } | j | j t t | d t d S( NRd ( R R R1 Ro RÈ t setattrRW ( R R ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_daemonize_active_threadÄ s
|
( R R RÉ RÊ RË RÍ ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRÇ ´ s t LockTestsc B s e Z e e j Z RS( ( R R t staticmethodR RJ t locktype( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRÎ Ê s t
|
RLockTestsc B s e Z e e j Z RS( ( R R RÏ R R( RÐ ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRÑ Í s t
|
EventTestsc B s e Z e e j Z RS( ( R R RÏ R R? t eventtype( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRÒ Ð s t ConditionAsRLockTestsc B s e Z e e j Z RS( ( R R RÏ R t ConditionRÐ ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRÔ Ó s t ConditionTestsc B s e Z e e j Z RS( ( R R RÏ R RÕ t condtype( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRÖ × s t SemaphoreTestsc B s e Z e e j Z RS( ( R R RÏ R t Semaphoret semtype( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRØ Ú s t BoundedSemaphoreTestsc B s; e Z e e j Z e j e j d k d d Z
|
RS( t darwins test macosx problemc C s d } d } t j t j d | g d t j } | j \ } } | j j d d } | j | j d d | j | | d S( Ns} if True:
|
import threading
|
|
def recurse():
|
return recurse()
|
|
def outer():
|
try:
|
recurse()
|
except RuntimeError:
|
pass
|
|
w = threading.Thread(target=outer)
|
w.start()
|
w.join()
|
print('end of main thread')
|
s end of main thread
|
s -cRx s R i s Unexpected error(
|
Rr Rz Rt Ru R{ R~ R¹ R² R+ R ( R R³ Rº R Rx Ry R´ ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_recursion_limità s ( R R RÏ R R' RÚ R§ R¨ Rt RÆ RÝ ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyRÛ Ý s c C s/ t j j t t t t t t t t
|
t t
|
d S( N( R R t run_unittestRÎ RÑ RÒ RÔ RÖ RØ RÛ R& R« RÇ ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt test_main s t __main__($ t test.test_supportR R t test.script_helperR R R. Rt R t import_moduleR R R R§ R Rª Rr R R R R R t TestCaseR R& R« RÇ RÎ RÑ RÒ RÔ RÖ RØ RÛ Rß R ( ( ( s[ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/test/test_threading.pyt <module> s<
|
ÿ xõ#
|
