Sik/tradingbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Make main loop to repeat every 1 sec

Browse Source
This commit is contained in:
Sik Yoon 2023-12-04 22:53:14 +09:00
parent 4a1ebd3034
commit e75d70120a
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main.rs
View File

@ -1496,6 +1496,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
// println!("test limit order 실행"); // println!("test limit order 실행");
// let client = ClientBuilder::new().timeout(Duration::from_millis(1000)).build().unwrap(); // let client = ClientBuilder::new().timeout(Duration::from_millis(1000)).build().unwrap();
// limit_order_buy_test(&client).await; // limit_order_buy_test(&client).await;
let instant = Instant::now();
let mut elapsed_time = 0;
let capacity_vec_1 = tradefee_vec_capacity.borrow().clone(); let capacity_vec_1 = tradefee_vec_capacity.borrow().clone();
let capacity_vec_2 = valid_usdt_trade_vec_capacity.borrow().clone(); let capacity_vec_2 = valid_usdt_trade_vec_capacity.borrow().clone();
let capacity_vec_3 = price_vec_capacity.borrow().clone(); let capacity_vec_3 = price_vec_capacity.borrow().clone();
@ -1526,8 +1528,11 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
capacity_vec_12.capacity(), capacity_vec_12.capacity(),
capacity_vec_13.capacity(), capacity_vec_13.capacity(),
capacity_vec_14.capacity()); capacity_vec_14.capacity());
sleep(Duration::from_secs(1)).await; elapsed_time = instant.elapsed().as_millis();
if 1_000 > elapsed_time {
sleep(Duration::from_millis((1_000 - elapsed_time) as u64)).await;
}
} }
Ok(()) Ok(())