А⚙
Та блин
self.get_possible_matches(&mut *order)Size: a a a
2020 August 15
АК
Написал выеше
АК
В чём причина того что не сработало? Говорили что пофиксили чекер в 2018 и не надо так писать больше.
EG
Не работает? @ozkriff, полагаю.
РФ
Он вроде устал
EG
Такой вопрос
У меня есть несколько (не очень много) внешних сущностей (процессов, вебсокетов)
Мне нужно отправить в каждую информацию, получить ответ, потом повторить. Т. е. сначала я жду ответа от всех, и только потом начинаю снова посылать запросы, причём ответ жду с таймаутом.
Я не уверен, как это лучше сделать.
Можно порождать тред на каждого клиента. Можно вместо этого их спаунить в асинк-тасках, наверное? Но я не могу сходу придумать, как в Rust это сделать на них. Ещё есть actix с акторами, которые, вроде как, тоже подходят под проблему.
У меня есть несколько (не очень много) внешних сущностей (процессов, вебсокетов)
Мне нужно отправить в каждую информацию, получить ответ, потом повторить. Т. е. сначала я жду ответа от всех, и только потом начинаю снова посылать запросы, причём ответ жду с таймаутом.
Я не уверен, как это лучше сделать.
Можно порождать тред на каждого клиента. Можно вместо этого их спаунить в асинк-тасках, наверное? Но я не могу сходу придумать, как в Rust это сделать на них. Ещё есть actix с акторами, которые, вроде как, тоже подходят под проблему.
EG
select!(timeout_future, futures.join_all())
Кажется, так выражается то, что я хочу сказать
EG
Но это оставляет вопросы, где хранить футуры, чтобы они не дропнулись
Сделать, типа,
?
Сделать, типа,
struct State {
channels: Vec<Channel>,
clients: Vec<Future>,
}?
Э
Такой вопрос
У меня есть несколько (не очень много) внешних сущностей (процессов, вебсокетов)
Мне нужно отправить в каждую информацию, получить ответ, потом повторить. Т. е. сначала я жду ответа от всех, и только потом начинаю снова посылать запросы, причём ответ жду с таймаутом.
Я не уверен, как это лучше сделать.
Можно порождать тред на каждого клиента. Можно вместо этого их спаунить в асинк-тасках, наверное? Но я не могу сходу придумать, как в Rust это сделать на них. Ещё есть actix с акторами, которые, вроде как, тоже подходят под проблему.
У меня есть несколько (не очень много) внешних сущностей (процессов, вебсокетов)
Мне нужно отправить в каждую информацию, получить ответ, потом повторить. Т. е. сначала я жду ответа от всех, и только потом начинаю снова посылать запросы, причём ответ жду с таймаутом.
Я не уверен, как это лучше сделать.
Можно порождать тред на каждого клиента. Можно вместо этого их спаунить в асинк-тасках, наверное? Но я не могу сходу придумать, как в Rust это сделать на них. Ещё есть actix с акторами, которые, вроде как, тоже подходят под проблему.
let mut connections: Vec<_> = /* */;
connections.iter_mut().for_each(|x| x.set_nonblocking().unwrap());
// Vec<bool> with the length of the connections.
let mut is_ok = BitVec;
let mut ok_resp = Vec::new();
loop {
let deadline = Instant::now() + SOME_DURATION;
while Instant::now() < deadline {
for idx in (0..connections.len()).rev() {
let c = connections[idx];
if !is_ok.get(idx) {
match c.read(buf) {
Ok(n) => { is_ok.set(idx); ok_resp.push((c.socket(), n)); },
Err(_) => (),
}
}
}
}
for idx in (0..connections.len()).rev() {
if !is_ok.get(idx) { connections.swap_remove(idx); }
}
is_ok.truncate(connections.len());
is_ok.unset_all();
/* На оставшиеся фигачишь дальше */
}
EG
let mut connections: Vec<_> = /* */;
connections.iter_mut().for_each(|x| x.set_nonblocking().unwrap());
// Vec<bool> with the length of the connections.
let mut is_ok = BitVec;
let mut ok_resp = Vec::new();
loop {
let deadline = Instant::now() + SOME_DURATION;
while Instant::now() < deadline {
for idx in (0..connections.len()).rev() {
let c = connections[idx];
if !is_ok.get(idx) {
match c.read(buf) {
Ok(n) => { is_ok.set(idx); ok_resp.push((c.socket(), n)); },
Err(_) => (),
}
}
}
}
for idx in (0..connections.len()).rev() {
if !is_ok.get(idx) { connections.swap_remove(idx); }
}
is_ok.truncate(connections.len());
is_ok.unset_all();
/* На оставшиеся фигачишь дальше */
}
Немного сурово
Хотелось бы как-то более высокоуровнево
Хотелось бы как-то более высокоуровнево
Э
Можешь в match по .read сделать ветку
Err(e) if e.kind() == WouldBlock => (),
Err(_) => { connections.swap_remove(idx); }EG
let mut connections: Vec<_> = /* */;
connections.iter_mut().for_each(|x| x.set_nonblocking().unwrap());
// Vec<bool> with the length of the connections.
let mut is_ok = BitVec;
let mut ok_resp = Vec::new();
loop {
let deadline = Instant::now() + SOME_DURATION;
while Instant::now() < deadline {
for idx in (0..connections.len()).rev() {
let c = connections[idx];
if !is_ok.get(idx) {
match c.read(buf) {
Ok(n) => { is_ok.set(idx); ok_resp.push((c.socket(), n)); },
Err(_) => (),
}
}
}
}
for idx in (0..connections.len()).rev() {
if !is_ok.get(idx) { connections.swap_remove(idx); }
}
is_ok.truncate(connections.len());
is_ok.unset_all();
/* На оставшиеся фигачишь дальше */
}
Подожди, тут чтение получается не параллельное
Э
Нонблочное.
EG
А, в самом деле. Энивей, это какое-то переизобретение ивентлупа, кажется.
ph
Такой вопрос
У меня есть несколько (не очень много) внешних сущностей (процессов, вебсокетов)
Мне нужно отправить в каждую информацию, получить ответ, потом повторить. Т. е. сначала я жду ответа от всех, и только потом начинаю снова посылать запросы, причём ответ жду с таймаутом.
Я не уверен, как это лучше сделать.
Можно порождать тред на каждого клиента. Можно вместо этого их спаунить в асинк-тасках, наверное? Но я не могу сходу придумать, как в Rust это сделать на них. Ещё есть actix с акторами, которые, вроде как, тоже подходят под проблему.
У меня есть несколько (не очень много) внешних сущностей (процессов, вебсокетов)
Мне нужно отправить в каждую информацию, получить ответ, потом повторить. Т. е. сначала я жду ответа от всех, и только потом начинаю снова посылать запросы, причём ответ жду с таймаутом.
Я не уверен, как это лучше сделать.
Можно порождать тред на каждого клиента. Можно вместо этого их спаунить в асинк-тасках, наверное? Но я не могу сходу придумать, как в Rust это сделать на них. Ещё есть actix с акторами, которые, вроде как, тоже подходят под проблему.
Э
Ну, насколько я знаю, тот же RA таки переизобрёл ивент луп под себя.
Э
Там по количеству коннекшонов, а не по таймеру, не?
EG
Ну, насколько я знаю, тот же RA таки переизобрёл ивент луп под себя.
Мне не нужна безумная производительность RA для анализа мегабайтов кода
ph
Таймер делается через таймаут. Это часть "жду ответа от всех"