交易算法开发：针对特定股票终止While循环并继续处理其他股票

你的核心需求是让每只股票的LTP监控循环独立运行，当某只股票触发止损/止盈时终止自身循环，其他股票继续监控。原代码的问题在于串行调用监控逻辑，导致后一只股票的监控要等前一只结束才开始，无法满足并行监控的需求。下面提供两种可行的实现方案：

方案一：多线程并行监控（推荐） #

通过多线程让每只股票的监控逻辑独立运行，某只股票触发条件终止后，不影响其他股票的监控流程：

import threading
import time  # 模拟API调用延迟，实际开发替换为真实API逻辑

stock_list = ["s1", "s2"]

def get_ltp(stock):
    # 模拟从API获取单只股票的最新成交价
    print(f"获取 {stock} 的LTP...")
    time.sleep(0.5)
    # 模拟不同股票的价格波动，实际替换为API返回值
    return 100 + (ord(stock[-1]) - ord('1')) * 5

def monitor_single_stock(stock, entry_ltp):
    sl = entry_ltp * 0.99  # 1%止损
    tgt = entry_ltp * 1.01  # 1%止盈
    print(f"开始监控 {stock} | 止损价: {sl:.2f} | 止盈价: {tgt:.2f}")
    
    while True:
        current_ltp = get_ltp(stock)
        
        # 触发止损
        if current_ltp <= sl:
            print(f"{stock} 触发止损！当前LTP: {current_ltp:.2f}，执行卖出")
            break
        # 触发止盈
        elif current_ltp >= tgt:
            print(f"{stock} 触发止盈！当前LTP: {current_ltp:.2f}，执行卖出")
            break
        
        # 控制API调用频率，避免限流
        time.sleep(1)

def buy_and_monitor():
    for stock in stock_list:
        # 模拟买入动作，获取买入时的成交价
        entry_ltp = get_ltp(stock)
        print(f"买入 {stock}，成交价: {entry_ltp:.2f}")
        
        # 为每只股票启动独立监控线程
        thread = threading.Thread(target=monitor_single_stock, args=(stock, entry_ltp))
        thread.start()

if __name__ == "__main__":
    buy_and_monitor()

关键说明 #

• 每个股票的监控逻辑在独立线程中运行，相互不阻塞
• get_ltp函数专门负责获取单只股票的实时价格，确保监控数据的时效性
• 同时处理止损和止盈两种触发条件，触发后立即终止当前股票的监控循环
• 加入time.sleep控制API调用频率，适配大多数API的限流规则

方案二：单循环轮询监控（无多线程） #

如果不想使用多线程，可以在一个主循环中轮询所有未触发条件的股票，每次检查后移除已完成监控的股票：

import time

stock_list = ["s1", "s2"]
active_stocks = []  # 存储正在监控的股票及参数

def get_ltp(stock):
    # 模拟API获取LTP
    print(f"获取 {stock} 的LTP...")
    time.sleep(0.5)
    return 100 + (ord(stock[-1]) - ord('1')) * 5

def buy_stocks():
    for stock in stock_list:
        entry_ltp = get_ltp(stock)
        sl = entry_ltp * 0.99
        tgt = entry_ltp * 1.01
        active_stocks.append({
            "stock": stock,
            "sl": sl,
            "tgt": tgt
        })
        print(f"买入 {stock} | 成交价: {entry_ltp:.2f} | 止损: {sl:.2f} | 止盈: {tgt:.2f}")

def monitor_all_stocks():
    while active_stocks:
        # 遍历列表副本，避免修改原列表时引发遍历异常
        for stock_info in active_stocks.copy():
            stock = stock_info["stock"]
            current_ltp = get_ltp(stock)
            
            if current_ltp <= stock_info["sl"]:
                print(f"{stock} 触发止损！执行卖出")
                active_stocks.remove(stock_info)
            elif current_ltp >= stock_info["tgt"]:
                print(f"{stock} 触发止盈！执行卖出")
                active_stocks.remove(stock_info)
        
        time.sleep(1)

if __name__ == "__main__":
    buy_stocks()
    monitor_all_stocks()

关键说明 #

• 主循环持续运行，直到所有股票都触发条件
• 每次遍历活跃股票的副本，避免在遍历过程中修改列表导致错误
• 逻辑简单易懂，适合对多线程不熟悉的开发者

内容的提问来源于stack exchange，提问作者Shankar