equal
deleted
inserted
replaced
109 self.job.do() |
109 self.job.do() |
110 self.done.notify_all() |
110 self.done.notify_all() |
111 self.mutex.release() |
111 self.mutex.release() |
112 |
112 |
113 def call(self, *args, **kwargs): |
113 def call(self, *args, **kwargs): |
114 print("call", args, kwargs) |
|
115 """ |
114 """ |
116 creates a job, execute it in worker thread, and deliver result. |
115 creates a job, execute it in worker thread, and deliver result. |
117 if job execution raise exception, re-raise same exception |
116 if job execution raise exception, re-raise same exception |
118 meant to be called by non-worker threads, but this is accepted. |
117 meant to be called by non-worker threads, but this is accepted. |
119 blocking until job done |
118 blocking until job done |