| | |
|---|
| | | * 下单 REST API 调用可能耗时数百毫秒，若同步执行会阻塞 WS 回调线程，导致心跳超时误判。 |
|---|
| | | * 本类将所有 REST 调用提交到独立线程池异步执行。 |
|---|
| | | * |
|---|
| | | * <h3>回调设计</h3> |
|---|
| | | * 每个下单方法接受 onSuccess/onFailure 两个 Runnable。 |
|---|
| | | * 基底开仓时 onSuccess 用于标记基底已开，网格触发时通常为 null（成交状态由仓位推送驱动）。 |
|---|
| | | * |
|---|
| | | * <h3>线程模型</h3> |
|---|
| | | * 单线程 ThreadPoolExecutor + 有界队列 64 + CallerRunsPolicy： |
|---|
| | | * <ul> |
|---|
| | | * <li><b>单线程</b>：保证下单顺序（开多→开空→止盈单），避免并发竞争</li> |
|---|
| | | * <li><b>有界队列 64</b>：防止堆积。极端行情下最多累积 64 个任务</li> |
|---|
| | |
|---|
| | | * |
|---|
| | | * <h3>调用链</h3> |
|---|
| | | * <pre> |
|---|
| | | * GateGridTradeService.onKline → executor.openLong/openShort → REST API |
|---|
| | | * GateGridTradeService.onPositionUpdate → executor.openLong/openShort → REST API |
|---|
| | | * (每一次开仓后) → executor.placeTakeProfit → REST API |
|---|
| | | * GateGridTradeService.onKline → executor.openLong/openShort (基底双开 + 网格触发) |
|---|
| | | * GateGridTradeService.onPositionUpdate → executor.placeTakeProfit (开仓成交后设止盈) |
|---|
| | | * GateGridTradeService.stopGrid → executor.cancelAllPriceTriggeredOrders |
|---|
| | | * </pre> |
|---|
| | | * |
|---|
| | | * @author Administrator |
|---|
