Administrator
2024-01-22 9fb8df2f64a1ce11a62bcb31ee550812162b7e41
交易金额改为2w
1个文件已修改
1个文件已添加
25 ■■■■■ 已修改文件
constant.py 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
test/test_shared_memery.py 23 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
constant.py
@@ -148,7 +148,7 @@
########华鑫配置########
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
test/test_shared_memery.py
New file
@@ -0,0 +1,23 @@
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()