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

Delete unnecessary threading

Browse Source
This commit is contained in:
Sik Yoon 2024-01-13 19:50:35 +09:00
parent 830be77c03
commit 2d82a17f0e
1 changed files with 4 additions and 76 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
src/strategy_team/strategy_manager.rs
View File

@ -73,83 +73,11 @@ pub async fn execute_list_up_for_sell(
exchange_info_vec: &Vec<ExchangeInfo>,
trade_fee_vec: &Vec<TradeFee>,
) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let all_data_c1 = all_data.clone();
let all_data_c2 = all_data.clone();
// let all_data_c3 = all_data.clone();
let all_data_c4 = all_data.clone();
// let all_data_c5 = all_data.clone();
let all_data_c6 = all_data.clone();
crate::strategy_team::strategy_001::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?;
crate::strategy_team::strategy_002::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?;
crate::strategy_team::strategy_004::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?;
crate::strategy_team::strategy_006::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?;
let exchange_info_vec_c1 = exchange_info_vec.clone();
let exchange_info_vec_c2 = exchange_info_vec.clone();
// let exchange_info_vec_c3 = exchange_info_vec.clone();
let exchange_info_vec_c4 = exchange_info_vec.clone();
// let exchange_info_vec_c5 = exchange_info_vec.clone();
let exchange_info_vec_c6 = exchange_info_vec.clone();
let trade_fee_vec_c1 = trade_fee_vec.clone();
let trade_fee_vec_c2 = trade_fee_vec.clone();
// let trade_fee_vec_c3 = trade_fee_vec.clone();
let trade_fee_vec_c4 = trade_fee_vec.clone();
// let trade_fee_vec_c5 = trade_fee_vec.clone();
let trade_fee_vec_c6 = trade_fee_vec.clone();
let mut task_vec = Vec::new();
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_001::list_up_for_sell(
&all_data_c1,
&exchange_info_vec_c1,
&trade_fee_vec_c1,
)
.await;
}));
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_002::list_up_for_sell(
&all_data_c2,
&exchange_info_vec_c2,
&trade_fee_vec_c2,
)
.await;
}));
// task_vec.push(tokio::spawn(async move {
// crate::strategy_team::strategy_003::list_up_for_sell(
// &all_data_c3,
// &exchange_info_vec_c3,
// &trade_fee_vec_c3,
// )
// .await;
// }));
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_004::list_up_for_sell(
&all_data_c4,
&exchange_info_vec_c4,
&trade_fee_vec_c4,
)
.await;
}));
// task_vec.push(tokio::spawn(async move {
// crate::strategy_team::strategy_005::list_up_for_sell(
// &all_data_c5,
// &exchange_info_vec_c5,
// &trade_fee_vec_c5,
// )
// .await;
// }));
task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_006::list_up_for_sell(
&all_data_c6,
&exchange_info_vec_c6,
&trade_fee_vec_c6,
)
.await;
}));
try_join_all(task_vec).await?;
Ok(())
}