| | |
|---|
| | | import queue |
|---|
| | | import time |
|---|
| | | |
|---|
| | | from l2.cancel_buy_strategy import LCancelRateManager |
|---|
| | | |
|---|
| | | __queue = queue.Queue() |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | p1, p2 = multiprocessing.Pipe() |
|---|
| | | # L1订阅数据 |
|---|
| | | progress1 = multiprocessing.Process(target=lambda: test_process_1(p1)) |
|---|
| | | progress2 = multiprocessing.Process(target=lambda: test_process_2(p2)) |
|---|
| | | progress1.start() |
|---|
| | | progress2.start() |
|---|
| | | |
|---|
| | | input() |
|---|
| | | code = "000333" |
|---|
| | | LCancelRateManager.set_block_limit_up_count(code, 100) |
|---|
| | | LCancelRateManager.set_big_num_deal_rate(code, 10) |
|---|
| | | print(LCancelRateManager.get_cancel_rate(code)) |
|---|
