Python中如何实现自动化交易，一单成交后其他单作废？

import threading
import time
from queue import Queue
import random

class AutoTradeSystem:
    def __init__(self):
        self.order_queue = Queue()
        self.active_order = None
        self.order_lock = threading.Lock()
        self.is_running = True
        
    def place_order(self, order_id, symbol, price, quantity):
        """模拟下单函数"""
        with self.order_lock:
            if self.active_order is None:
                self.active_order = {
                    'id': order_id,
                    'symbol': symbol,
                    'price': price,
                    'quantity': quantity,
                    'status': 'pending'
                }
                print(f"订单 {order_id} 已提交: {symbol}@{price} x{quantity}")
                return True
            else:
                print(f"订单 {order_id} 被拒绝: 已有活跃订单 {self.active_order['id']}")
                return False
    
    def check_order_status(self):
        """模拟检查订单状态"""
        if self.active_order and self.active_order['status'] == 'pending':
            # 模拟50%的成交概率
            if random.random() > 0.5:
                self.active_order['status'] = 'filled'
                print(f"订单 {self.active_order['id']} 已成交!")
                return True
        return False
    
    def cancel_all_pending(self):
        """取消所有挂单"""
        with self.order_lock:
            if self.active_order and self.active_order['status'] == 'pending':
                print(f"取消订单 {self.active_order['id']}")
                self.active_order = None
    
    def trading_strategy(self):
        """交易策略线程"""
        order_counter = 1
        while self.is_running:
            # 生成模拟交易信号
            symbol = "BTC/USDT"
            price = round(50000 + random.uniform(-100, 100), 2)
            quantity = random.randint(1, 10)
            
            # 尝试下单
            success = self.place_order(f"ORD{order_counter}", symbol, price, quantity)
            if success:
                order_counter += 1
                
                # 等待订单状态更新
                for _ in range(10):  # 最多检查10次
                    if self.check_order_status():
                        break
                    time.sleep(0.1)
                
                # 如果订单成交，取消其他挂单
                if self.active_order and self.active_order['status'] == 'filled':
                    self.cancel_all_pending()
                    self.active_order = None
            
            time.sleep(1)  # 策略执行间隔
    
    def run(self):
        """启动交易系统"""
        print("启动自动化交易系统...")
        strategy_thread = threading.Thread(target=self.trading_strategy)
        strategy_thread.start()
        
        try:
            while True:
                time.sleep(1)
        except KeyboardInterrupt:
            self.is_running = False
            print("\n停止交易系统")

# 使用示例
if __name__ == "__main__":
    trader = AutoTradeSystem()
    trader.run()

核心思路是用一个active_order变量跟踪当前活跃订单，配合线程锁保证状态一致性。下单前检查是否有活跃订单，有则拒绝新单；订单成交后立即清空active_order状态。这样确保同一时间只有一个有效订单。

简单说就是用一个标志位控制订单状态流转。

同问现在有什么其他好办法么？除了那种要不少钱的。。。。。小钱瞎玩 不值当