Skip to content
Snippets Groups Projects
Commit 241fc7f0 authored by Danilo Piparo's avatar Danilo Piparo
Browse files

[JupyROOT] Improve code logic and adapt test

parent c58b7b9c
Branches
Tags
No related merge requests found
...@@ -88,6 +88,7 @@ class Poller(Thread): ...@@ -88,6 +88,7 @@ class Poller(Thread):
self.ro_ref().is_running = False self.ro_ref().is_running = False
else: else:
self.poll = False self.poll = False
self.ro_ref().is_running = False
return return
class Runner(object): class Runner(object):
...@@ -107,7 +108,7 @@ class Runner(object): ...@@ -107,7 +108,7 @@ class Runner(object):
>>> r.AsyncRun("Asynchronous");print("Synchronous");time.sleep(1) >>> r.AsyncRun("Asynchronous");print("Synchronous");time.sleep(1)
Synchronous Synchronous
Asynchronous Asynchronous
>>> r.AsyncRun("Asynchronous"); print(r.HasFinished()) >>> r.AsyncRun("Asynchronous"); time.sleep(.2); print(r.HasFinished())
False False
>>> time.sleep(1) >>> time.sleep(1)
Asynchronous Asynchronous
...@@ -131,20 +132,16 @@ class Runner(object): ...@@ -131,20 +132,16 @@ class Runner(object):
return self.function(argument) return self.function(argument)
def AsyncRun(self, argument): def AsyncRun(self, argument):
self.is_running = True
self.argument_queue.put(argument) self.argument_queue.put(argument)
def Wait(self): def Wait(self):
while self.is_running: pass while self.is_running: pass
def HasFinished(self): def HasFinished(self):
if self.is_running: return False return False if self.is_running else True
return True
def Stop(self): def Stop(self):
self.Wait()
self.argument_queue.put(None) self.argument_queue.put(None)
self.Wait()
class JupyROOTDeclarer(Runner): class JupyROOTDeclarer(Runner):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment