blob: 9274340b5caa574a9220019271119f02906eb67a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
#![warn(clippy::future_not_send)]
use std::cell::Cell;
use std::rc::Rc;
use std::sync::Arc;
async fn private_future(rc: Rc<[u8]>, cell: &Cell<usize>) -> bool {
//~^ ERROR: future cannot be sent between threads safely
async { true }.await
}
pub async fn public_future(rc: Rc<[u8]>) {
//~^ ERROR: future cannot be sent between threads safely
async { true }.await;
}
pub async fn public_send(arc: Arc<[u8]>) -> bool {
async { false }.await
}
async fn private_future2(rc: Rc<[u8]>, cell: &Cell<usize>) -> bool {
//~^ ERROR: future cannot be sent between threads safely
true
}
pub async fn public_future2(rc: Rc<[u8]>) {}
//~^ ERROR: future cannot be sent between threads safely
pub async fn public_send2(arc: Arc<[u8]>) -> bool {
false
}
struct Dummy {
rc: Rc<[u8]>,
}
impl Dummy {
async fn private_future(&self) -> usize {
//~^ ERROR: future cannot be sent between threads safely
async { true }.await;
self.rc.len()
}
pub async fn public_future(&self) {
//~^ ERROR: future cannot be sent between threads safely
self.private_future().await;
}
#[allow(clippy::manual_async_fn)]
pub fn public_send(&self) -> impl std::future::Future<Output = bool> {
async { false }
}
}
async fn generic_future<T>(t: T) -> T
//~^ ERROR: future cannot be sent between threads safely
where
T: Send,
{
let rt = &t;
async { true }.await;
let _ = rt;
t
}
async fn generic_future_send<T>(t: T)
where
T: Send,
{
async { true }.await;
}
async fn unclear_future<T>(t: T) {}
//~^ ERROR: future cannot be sent between threads safely
fn main() {
let rc = Rc::new([1, 2, 3]);
private_future(rc.clone(), &Cell::new(42));
public_future(rc.clone());
let arc = Arc::new([4, 5, 6]);
public_send(arc);
generic_future(42);
generic_future_send(42);
let dummy = Dummy { rc };
dummy.public_future();
dummy.public_send();
}
|
