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

Rollback threading

Browse Source
This commit is contained in:
Sik Yoon 2024-01-13 17:14:09 +09:00
parent f548c0b63c
commit ec4ea20d84
1 changed files with 81 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

91
src/strategy_team/strategy_manager.rs
View File

@ -33,16 +33,16 @@ pub async fn execute_list_up_for_buy(
all_data: &AllData, all_data: &AllData,
) -> Result<(), Box<dyn std::error::Error + Send + Sync>> { ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let mut task_vec = Vec::new(); let mut task_vec = Vec::new();
// let all_data_c1 = all_data.clone(); let all_data_c1 = all_data.clone();
let all_data_c2 = all_data.clone(); let all_data_c2 = all_data.clone();
// let all_data_c3 = all_data.clone(); // let all_data_c3 = all_data.clone();
let all_data_c4 = all_data.clone(); let all_data_c4 = all_data.clone();
// let all_data_c5 = all_data.clone(); // let all_data_c5 = all_data.clone();
let all_data_c6 = all_data.clone(); let all_data_c6 = all_data.clone();
// task_vec.push(tokio::spawn(async move { task_vec.push(tokio::spawn(async move {
// crate::strategy_team::strategy_001::list_up_for_buy(all_data_c1).await; crate::strategy_team::strategy_001::list_up_for_buy(all_data_c1).await;
// })); }));
task_vec.push(tokio::spawn(async move { task_vec.push(tokio::spawn(async move {
crate::strategy_team::strategy_002::list_up_for_buy(all_data_c2).await; crate::strategy_team::strategy_002::list_up_for_buy(all_data_c2).await;
@ -73,12 +73,83 @@ pub async fn execute_list_up_for_sell(
exchange_info_vec: &Vec<ExchangeInfo>, exchange_info_vec: &Vec<ExchangeInfo>,
trade_fee_vec: &Vec<TradeFee>, trade_fee_vec: &Vec<TradeFee>,
) -> Result<(), Box<dyn std::error::Error + Send + Sync>> { ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
// crate::strategy_team::strategy_001::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?; let all_data_c1 = all_data.clone();
crate::strategy_team::strategy_002::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?; let all_data_c2 = all_data.clone();
// crate::strategy_team::strategy_003::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?; // let all_data_c3 = all_data.clone();
crate::strategy_team::strategy_004::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?; let all_data_c4 = all_data.clone();
// crate::strategy_team::strategy_005::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?; // let all_data_c5 = all_data.clone();
crate::strategy_team::strategy_006::list_up_for_sell(&all_data, &exchange_info_vec, &trade_fee_vec).await?; let all_data_c6 = all_data.clone();
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(()) Ok(())
} }