Browse Source

怀疑是数组增长之后没有及时清掉,导致遍历时间越来越长。

skyffire 1 năm trước cách đây
mục cha
commit
33de1bb7c4
1 tập tin đã thay đổi với 2 bổ sung16 xóa
  1. 2 16
      strategy/src/core.rs

+ 2 - 16
strategy/src/core.rs

@@ -24,7 +24,7 @@ use standard::{Account, Market, Order, OrderCommand, Platform, Position, Positio
 use standard::exchange::{Exchange};
 use standard::exchange::ExchangeEnum::{BinanceSwap, GateSwap};
 
-use crate::model::{LocalPosition, OrderInfo, OriginalTradeBa, TokenParam};
+use crate::model::{LocalPosition, OrderInfo, TokenParam};
 use crate::predictor::Predictor;
 use crate::strategy::Strategy;
 use crate::utils;
@@ -108,14 +108,6 @@ pub struct Core {
     pub prev_log_ready_timestamp: i64,
     pub log_ready_log_interval: i64,
 
-    // 订单流相关参数
-    pub side: String,                                       // 当前方向, [normal, long, short]
-    pub trades: Vec<OriginalTradeBa>,                       // 订单流集合
-    pub recall_time: Decimal,                               // 前置时间
-    pub recall_max_count: usize,                            // 最大回溯条数
-    pub short_volume_rate: Decimal,                         // 主动性跌比率(0.01代表1%)
-    pub long_volume_rate: Decimal,                          // 主动性涨比率(0.01代表1%)
-
     // 中控
     pub cci_arc: Arc<Mutex<CentralControlInfo>>,            // 中控信息汇集
 
@@ -246,12 +238,6 @@ impl Core {
             running,
             prev_log_ready_timestamp: 0,
             log_ready_log_interval: 10 * 1000,
-            side: "normal".to_string(),
-            trades: vec![],
-            recall_time: dec!(6180),
-            recall_max_count: 5000.to_usize().unwrap(),
-            short_volume_rate: dec!(0.618),
-            long_volume_rate: dec!(0.618),
             cci_arc,
             agg_market: vec![],
             ref_price: vec![],
@@ -671,6 +657,7 @@ impl Core {
                                                    &self.ref_price,
                                                    &self.predict,
                                                    &trace_stack.ins);
+                TraceStack::show_delay(&trace_stack.ins);
 
                 if orders.is_not_empty() {
                     // debug!("触发onTick");
@@ -678,7 +665,6 @@ impl Core {
                     //异步交易所处理订单信号
                     let mut platform_rest_fb = self.platform_rest.clone_box();
                     // info!("订单指令:{:?}", orders);
-                    TraceStack::show_delay(&trace_stack.ins);
                     let mut ts = trace_stack.clone();
                     ts.set_order_command(orders.to_string());
                     spawn(async move {