onexit()

onexit()函数用于处理策略的扫尾工作，最长执行时间为5分钟，需由用户自行实现。

示例

• 测试onexit()函数：

  • javascript
  • python
  • rust
  • cpp

  
      javascript
      
      
  function main(){
      Log("Starting, will stop after 5 seconds and execute cleanup function!")
      Sleep(1000 * 5)
  }
  
  // 扫尾函数的实现
  function onexit(){
      var beginTime = new Date().getTime()
      while(true){
          var nowTime = new Date().getTime()
          Log("Program stop countdown..cleanup started, elapsed time:", (nowTime - beginTime) / 1000, "seconds!")
          Sleep(1000)
      }
  }
  

  
      python
      
      
  import time
  def main():
      Log("Starting, will stop after 5 seconds and execute cleanup function!")
      Sleep(1000 * 5)
  
  def onexit():
      beginTime = time.time() * 1000
      while True:
          ts = time.time() * 1000
          Log("Program stop countdown..cleanup started, elapsed time:", (ts - beginTime) / 1000, "seconds!")
          Sleep(1000)
  

  
      rust
      
      
  fn main() {
      Log!("Starting, will stop after 5 seconds and execute cleanup function!");
      Sleep(1000 * 5);
  }
  
  // 扫尾函数的实现
  fn onexit() {
      let beginTime = Unix() * 1000;
      loop {
          let nowTime = Unix() * 1000;
          Log!("Program stop countdown..cleanup started, elapsed time:", (nowTime - beginTime) / 1000, "seconds!");
          Sleep(1000);
      }
  }
  

  
      c++
      
      
  void main() {
      Log("Starting, will stop after 5 seconds and execute cleanup function!");
      Sleep(1000 * 5);
  }
  
  void onexit() {
      auto beginTime = Unix() * 1000;
      while(true) {
          auto ts = Unix() * 1000;
          Log("Program stop countdown..cleanup started, elapsed time:", (ts - beginTime) / 1000, "seconds!");
          Sleep(1000);
      }
  }
  

• 由于回测系统中的策略通常被设计为一个死循环，不断轮询执行，因此在回测系统中无法触发策略所实现的onexit()函数。可以通过检测回测系统的结束标记（EOF 异常）来触发onexit()函数的执行。

  • javascript
  • python
  • rust
  • cpp

  
      javascript
      
      
  function main() {
      if (exchange.GetName().startsWith("Futures_")) {
          Log("Exchange is futures")
          exchange.SetContractType("swap")
      } else {
          Log("Exchange is spot")
      }
  
      if (IsVirtual()) {
          try {
              onTick()
          } catch (e) {
              Log("error:", e)
          }
      } else {
          onTick()
      }
  }
  
  function onTick() {
      while (true) {
          var ticker = exchange.GetTicker()
          LogStatus(_D(), ticker ? ticker.Last : "--")
          Sleep(500)
      }
  }
  
  function onexit() {
      Log("Executing cleanup function")
  }
  

  
      python
      
      
  def main():
      if exchange.GetName().startswith("Futures_"):
          Log("Exchange is futures")
      else:
          Log("Exchange is spot")
  
      if IsVirtual():
          try:
              onTick()
          except Exception as e:
              Log(e)
      else:
          onTick()
  
  def onTick():
      while True:
          ticker = exchange.GetTicker()
          LogStatus(_D(), ticker["Last"] if ticker else "--")
          Sleep(500)
  
  def onexit():
      Log("Executing cleanup function")
  

  
      rust
      
      
  fn onTick() {
      loop {
          match exchange.GetTicker(None) {
              Ok(ticker) => LogStatus!(_D(None), ticker.Last),
              Err(e) => {
                  // 回测结束时，API 调用返回 Err，退出循环使 main 返回，从而触发 onexit() 扫尾函数
                  Log!("error:", e);
                  break;
              }
          }
          Sleep(500);
      }
  }
  
  fn main() {
      if exchange.GetName().starts_with("Futures_") {
          Log!("Exchange is futures");
          let _ = exchange.SetContractType("swap");
      } else {
          Log!("Exchange is spot");
      }
  
      onTick();
  }
  
  fn onexit() {
      Log!("Executing cleanup function");
  }
  

  
      c++
      
      
  #include <iostream>
  #include <exception>
  #include <string>
  
  void onTick() {
      while (true) {
          auto ticker = exchange.GetTicker();
          LogStatus(_D(), ticker);
          Sleep(500);
      }
  }
  
  void main() {
      std::string prefix = "Futures_";
      bool startsWith = exchange.GetName().substr(0, prefix.length()) == prefix;
      if (startsWith) {
          Log("Exchange is futures");
          exchange.SetContractType("swap");
      } else {
          Log("Exchange is spot");
      }
  
      if (IsVirtual()) {
          try {
              onTick();
          } catch (...) {
              std::cerr << "Caught unknown exception" << std::endl;
          }
      } else {
          onTick();
      }
  }
  
  void onexit() {
      Log("Executing cleanup function");
  }