(self, name, args)
| 31 | @register(inputs=['inp'], outputs=['out'], exclusive=True) |
| 32 | class RepeatProcess: |
| 33 | def __init__(self, name, args): |
| 34 | self.name = name |
| 35 | s1, r1 = Pipe() |
| 36 | s2, r2 = Pipe() |
| 37 | self.send = s1 |
| 38 | self.recv = r2 |
| 39 | |
| 40 | mp.set_start_method('fork') |
| 41 | self.p = Process(target=repeat, args=(10, s2, r1)) |
| 42 | self.p.start() |
| 43 | |
| 44 | def __del__(self): |
| 45 | try: |