Общий fn, channel и spawn
У меня есть этот код здесь: ( ссылка на игровую площадку)
use std::thread;
use std::sync::mpsc::channel;
fn run<T: Send>(task: fn() -> T) -> T {
let (tx, rx) = channel();
thread::spawn(move || {
tx.send(task());
});
rx.recv().unwrap()
}
fn main() {
let task = || 1 + 2;
let result = run(task);
println!("{}", result);
}
Но я получаю пожизненную ошибку, которую не могу понять.
<anon>:6:5: 6:18 error: the parameter type `T` may not live long enough [E0310]
<anon>:6 thread::spawn(move || {
^~~~~~~~~~~~~
<anon>:6:5: 6:18 help: consider adding an explicit lifetime bound `T: 'static`...
<anon>:6:5: 6:18 note: ...so that captured variable `tx` does not outlive the enclosing closure
<anon>:6 thread::spawn(move || {
^~~~~~~~~~~~~
<anon>:15:22: 15:26 error: mismatched types:
expected `fn() -> _`,
found `[closure <anon>:13:16: 13:24]`
(expected fn pointer,
found closure) [E0308]
<anon>:15 let result = run(task);
^~~~
Какие-либо предложения? Спасибо!
1 ответ
Решение
Сообщение об ошибке предлагает добавить 'static
привязан к параметру типа T
, Если вы сделаете это, он избавится от первой ошибки:
fn run<T: Send + 'static>(task: fn() -> T) -> T
'static
граница необходима, чтобы гарантировать, что значение, возвращаемое task
может пережить функцию где task
пробеги. Узнайте больше о 'static
продолжительность жизни.
Вторая ошибка в том, что вы передаете закрытие, а run
ожидает указатель на функцию. Один из способов исправить это, изменив task
от замыкания до фн:
fn task() -> u32 { 1 + 2 }
Вот полный рабочий код:
use std::thread;
use std::sync::mpsc::channel;
fn run<T: Send + 'static>(task: fn() -> T) -> T {
let (tx, rx) = channel();
thread::spawn(move || {
tx.send(task());
});
rx.recv().unwrap()
}
fn main() {
fn task() -> u32 { 1 + 2 }
let result = run(task);
println!("{}", result);
}