Lines Matching refs:spawn
93 thread::spawn(move || {
111 tokio::spawn(async move {
128 let handle = tokio::spawn(async move {
152 tokio::spawn(async move {
156 tokio::spawn(async move {
183 tokio::spawn(async move {
195 thread::spawn(move || {
226 tokio::spawn(async move {
242 tokio::spawn(async move {
254 thread::spawn(move || {
282 assert_ok!(tokio::spawn(async {
283 assert_ok!(tokio::spawn(async {
301 tokio::spawn(poll_fn(move |_| {
340 tokio::spawn(async {
346 thread::spawn(move || {
364 tokio::spawn(async {
370 thread::spawn(move || {
375 tokio::spawn(async move {
391 thread::spawn(move || {
394 handle.spawn(async move {
411 thread::spawn(move || {
412 handle.spawn(async move {
419 tokio::spawn(async {
453 tokio::spawn(async move {
474 tokio::spawn(async move {
490 tokio::spawn(async move { "hello" })
568 let jh1 = thread::spawn(move || {
576 let jh2 = thread::spawn(move || {
608 rt.spawn(async {
620 let srv = tokio::spawn(async move {
625 let cli = tokio::spawn(async move {
671 rt.spawn(Boom(Some(tx)));
701 tokio::spawn(async {})
735 tokio::spawn(async move {
769 rt.spawn(async move {
775 rt.spawn(async move {
785 h1.spawn(async move {
792 rt.spawn(async move {
822 tokio::spawn(async move {
830 tokio::spawn(async move {
899 thread::spawn(|| {
917 tokio::spawn(async move {
1001 tokio::spawn(async { })
1029 tokio::spawn(async { })
1070 tasks.push(task::spawn(async move {
1084 tasks.push(task::spawn(async move {
1096 let handle = task::spawn(async {