А что за Пирс?

Привет! Есть вопрос по Tokio(и фьючерсам в целом). Мне нужен такой примитив синхронизации, который позволит блокировать все задачи, которые будут обращаться к этому примитиву, и разблокировать их всех одновременно, когда примитив разрешит. Смотрю, что есть в Токио: https://tokio-rs.github.io/tokio/doc/tokio/sync/index.html

Barrier блокирует только наперед заданный набор задач. У меня количество неизвестно. Не подходит.

Semaphore теоретически подходит, но acquire скушивает по одному пермиту. Мне нужно чтобы не "кушал", чтобы просто выставлялся один общий неотчуждаемый пермит на всех.

Notify разблокирует ресурс только при первом обращения. При повторном обращении заблокирует опять. Мне нужно, чтобы ресурс разблокировался навсегда

В примере нет .status(). Там просто в консоль выводиться весь Result<...>

Привет! Есть вопрос по Tokio(и фьючерсам в целом). Мне нужен такой примитив синхронизации, который позволит блокировать все задачи, которые будут обращаться к этому примитиву, и разблокировать их всех одновременно, когда примитив разрешит. Смотрю, что есть в Токио: https://tokio-rs.github.io/tokio/doc/tokio/sync/index.html

Barrier блокирует только наперед заданный набор задач. У меня количество неизвестно. Не подходит.

Semaphore теоретически подходит, но acquire скушивает по одному пермиту. Мне нужно чтобы не "кушал", чтобы просто выставлялся один общий неотчуждаемый пермит на всех.

Notify разблокирует ресурс только при первом обращения. При повторном обращении заблокирует опять. Мне нужно, чтобы ресурс разблокировался навсегда

теперь компилится без ошибок но и в консоль ничего не выводит

вот такую функцию сделал:

async fn do_something() {
  let mut client = Client::default();

  let response = client.get("https://jsonplaceholder.typicode.com/todos/1")
      .send().await;

  println!("Response: {:?}", response);
}

и ее вызываю там где надо

а как вызываешь?

теперь компилится без ошибок но и в консоль ничего не выводит

вот такую функцию сделал:

async fn do_something() {
  let mut client = Client::default();

  let response = client.get("https://jsonplaceholder.typicode.com/todos/1")
      .send().await;

  println!("Response: {:?}", response);
}

и ее вызываю там где надо

В зависимости от задачи есть вариант заблочить RwLock'ом, взяв мутабельный доступ к локу, и отпустить его, когда надо дать доступ задачам. Но там задачи должны брать немутабельный доступ.

когда добавляю async к функции моей которая внутри impl Perform<LoginResponse> for Oper<Register> {

Проблема в том, что гарды завязаны на сам RwLock, то есть имеют ограниченный lifetime. То есть я не могу залочить, и потом когда-нибудь в будущем, в другой задаче, например, разблокировать. По этой же причине не подходит Mutex

Кажется проще написать самому обертку. А что за кейс такой, когда задач динамичное количество?