@:param strategy 策略
(self, strategy)
| 6 | |
| 7 | class ProcessWrapper(object): |
| 8 | def __init__(self, strategy): |
| 9 | """ |
| 10 | @:param |
| 11 | strategy 策略 |
| 12 | """ |
| 13 | self.__strategy = strategy |
| 14 | # 事件队列 |
| 15 | self.__event_queue = mp.Queue(10000) |
| 16 | # 时钟队列 |
| 17 | self.__clock_queue = mp.Queue(10000) |
| 18 | # 包装进程 |
| 19 | self.__proc = mp.Process(target=self._process) |
| 20 | self.__proc.start() |
| 21 | |
| 22 | def stop(self): |
| 23 | """ |