PP
Хорошо, скиньте пример, где у Вас не работает с move
Size: a a a
2020 December 09
MK
На какой сайт залить?
MB
Ну этому потоку нужно передавать ресивер канала. Возможно поможет указать move у замыкания.
MK
Ну этому потоку нужно передавать ресивер канала. Возможно поможет указать move у замыкания.
Мне пишет захвачен здесь
PP
Мне пишет захвачен здесь
(там еще место указывается, где именно, поэтому информативнее будет все-таки на код посмотреть)
MK
Сечас скину
MB
Ну мне трудно заниматься телепатией, но видимо ты пытаешься передать ссылку на ресивер
MK
И когда доходит время до чтение поток же ждать будет по умолчанию? Можно ли сделать что бы не ждал, а просто выполнял другие инструкции?
PP
желательно скинуть код, в котором нужно решить только вашу проблему (можно сделать пример проще, чем у вас, чтобы другим была яснее суть). здесь же неясно, что за
self.get.connection и тдMB
Раз код неполный, то покажи текст ошибки компилятора
PP
мне кажется, что жалуется он не на reciever, а на self, вы очень ловко его на 2 потока пытаетесь разделить
MK
желательно скинуть код, в котором нужно решить только вашу проблему (можно сделать пример проще, чем у вас, чтобы другим была яснее суть). здесь же неясно, что за
self.get.connection и тдИзвиняюсь, это просто хэш таблица в которой хранится структура и там только адрес пользователя
MK
pub fn run(&mut self) {
| --------- this data with an anonymous lifetime
...
51 | thread::spawn(move || {
| ___________________________________^
52 | | self.handle(receiver);
53 | | });
| |_____________________^ ...is captured here...
|
note: ...and is required to live as long as
| --------- this data with an anonymous lifetime
'_......
51 | thread::spawn(move || {
| ___________________________________^
52 | | self.handle(receiver);
53 | | });
| |_____________________^ ...is captured here...
|
note: ...and is required to live as long as
'static hereMK
--> src/network/udp.rs:51:21
|
51 | thread::spawn(move || {
| ^^^^^^^^^^^^^
error: aborting due to previous error
|
51 | thread::spawn(move || {
| ^^^^^^^^^^^^^
error: aborting due to previous error
PP
pub fn run(&mut self) {
| --------- this data with an anonymous lifetime
...
51 | thread::spawn(move || {
| ___________________________________^
52 | | self.handle(receiver);
53 | | });
| |_____________________^ ...is captured here...
|
note: ...and is required to live as long as
| --------- this data with an anonymous lifetime
'_......
51 | thread::spawn(move || {
| ___________________________________^
52 | | self.handle(receiver);
53 | | });
| |_____________________^ ...is captured here...
|
note: ...and is required to live as long as
'static hereну да, он жалуется на &mut self, а не на reciever
MK
А как это исправляется?
PP
А как это исправляется?
почитайте про параллельность в растбуке. Проблема в том, что вы хотите передать &mut ссылку в другой поток и при этом оставив объект еще и в этом потоке. это недопустимо
MB
А как это исправляется?
Если обоим потокам нужен shared state, то его нужно завернуть во что-то типа Arc<Mutex<...>>