| 15 | return self._result |
| 16 | |
| 17 | class Worker(Actor): |
| 18 | def submit(self, func, *args, **kwargs): |
| 19 | r = Result() |
| 20 | self.send((func, args, kwargs, r)) |
| 21 | return r |
| 22 | |
| 23 | def run(self): |
| 24 | while True: |
| 25 | func, args, kwargs, r = self.recv() |
| 26 | r.set_result(func(*args, **kwargs)) |
| 27 | |
| 28 | # Example use |
| 29 | if __name__ == '__main__': |