(self, t, call, args=[], kwargs={}, threaded=True)
| 51 | self.queue = PriorityQueue() |
| 52 | |
| 53 | def addJob(self, t, call, args=[], kwargs={}, threaded=True): |
| 54 | d = Deferred() |
| 55 | t += time() |
| 56 | j = Job(t, call, args, kwargs, d, threaded) |
| 57 | self.queue.put((t, j)) |
| 58 | return d |
| 59 | |
| 60 | |
| 61 | def removeJob(self, d): |
no test coverage detected