]> rtime.felk.cvut.cz Git - linux-conf-perf.git/commitdiff
Fix thread alive check
authorKarel Kočí <cynerd@email.cz>
Wed, 26 Aug 2015 17:28:41 +0000 (19:28 +0200)
committerKarel Kočí <cynerd@email.cz>
Wed, 26 Aug 2015 18:02:59 +0000 (20:02 +0200)
scripts/loop.py

index 70004d57524310c37abf972095a07e1b62c2ec31..91611658c6c45cfda4fa1007af75bf6a7ee88e72 100755 (executable)
@@ -53,6 +53,8 @@ __conflist__ = []
 __listlock__ = Lock()
 
 class prepareThread(Thread):
+       global __preparethread__
+       global __measurethread__
        def __init__(self, name='prepare'):
                Thread.__init__(self, name=name)
        def run(self):
@@ -66,12 +68,15 @@ class prepareThread(Thread):
                                return
                        __listlock__.acquire()
                        __conflist__.append((img, config))
-                       if not __measurethread__.isActive():
+                       if not __measurethread__.is_alive():
+                               __measurethread__ = measureThread()
                                __measurethread__.start()
                __listlock__.release()
                print('Prepare thread stop')
 
 class measureThread(Thread):
+       global __preparethread__
+       global __measurethread__
        def __init__(self, name='measure'):
                Thread.__init__(self, name=name)
        def run(self):
@@ -80,7 +85,8 @@ class measureThread(Thread):
                while not __terminate__ and len(__conflist__) > 0:
                        img, config = __conflist__.pop()
                        __listlock__.release()
-                       if not __preparethread__.isActive():
+                       if not __preparethread__.is_alive():
+                               __preparethread__ = prepareThread()
                                __preparethread__.start()
                        measure(img, config)
                        __listlock__.acquire()