| | |
| | | ########华鑫配置######## |
| | | if not is_windows() or True: |
| | | # 下单1手 |
| | | BUY_MONEY_PER_CODE = 500 if constant.IS_A else 10000 |
| | | BUY_MONEY_PER_CODE = 500 if constant.IS_A else 20000 |
| | | L2_SOURCE_TYPE = L2_SOURCE_TYPE_HUAXIN |
| | | JUEJIN_LOCAL_API = False |
| | | TRADE_WAY = TRADE_WAY_HUAXIN |
New file |
| | |
| | | import multiprocessing.shared_memory |
| | | |
| | | |
| | | def producer(shr): |
| | | with shr.txn() as shm: |
| | | for i in range(10): |
| | | shm[i] = i |
| | | |
| | | |
| | | def consumer(shr): |
| | | with shr.txn() as shm: |
| | | for i in range(10): |
| | | print(shm[i]) |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | with multiprocessing.shared_memory.SharedMemory(create=True, size=80) as shr: |
| | | p1 = multiprocessing.Process(target=producer, args=(shr,)) |
| | | p2 = multiprocessing.Process(target=consumer, args=(shr,)) |
| | | p1.start() |
| | | p2.start() |
| | | p1.join() |
| | | p2.join() |