| /wasmtime-44.0.1/tests/misc_testsuite/component-model-threading/ |
| H A D | threading-builtins.wast | 18 (import "" "thread.yield" (func $thread-yield (result i32)))
19 (import "" "thread.index" (func $thread-index (result i32)))
43 (export "thread-start" (func $thread-start))
79 (core func $thread-yield (canon thread.yield))
80 (core func $thread-index (canon thread.index))
82 (core func $thread-unsuspend (canon thread.unsuspend))
84 (core func $thread-suspend (canon thread.suspend))
91 (export "thread.index" (func $thread-index))
93 (export "thread.yield" (func $thread-yield))
106 (core func $thread.index (canon thread.index))
[all …]
|
| H A D | threading-trap-in-post-return.wast | 10 (core func $thread.new-indirect (canon thread.new-indirect $ft (table $memory "t")))
11 (core func $thread.suspend-to-suspended (canon thread.suspend-to-suspended))
12 (core func $thread.suspend (canon thread.suspend))
13 (core func $thread.unsuspend (canon thread.unsuspend))
14 (core func $thread.yield-to-suspended (canon thread.yield-to-suspended))
19 (import "" "thread.suspend" (func $thread.suspend (result i32)))
20 (import "" "thread.unsuspend" (func $thread.unsuspend (param i32)))
31 (export "thread.new-indirect" (func $thread.new-indirect))
33 (export "thread.suspend" (func $thread.suspend))
34 (export "thread.unsuspend" (func $thread.unsuspend))
[all …]
|
| H A D | many-threads-indexed.wast | 34 (import "" "thread.suspend" (func $thread-suspend (result i32)))
37 (import "" "thread.yield" (func $thread-yield (result i32)))
38 (import "" "thread.index" (func $thread-index (result i32)))
58 (export "thread-start" (func $thread-start))
103 (core func $thread-yield (canon thread.yield))
104 (core func $thread-index (canon thread.index))
106 (core func $thread-unsuspend (canon thread.unsuspend))
108 (core func $thread-suspend (canon thread.suspend))
115 (export "thread.index" (func $thread-index))
117 (export "thread.yield" (func $thread-yield))
[all …]
|
| H A D | suspend-trap.wast | 4 ;; Test that a thread which is not suspended cannot be resumed
11 (import "" "thread.new-indirect" (func $thread.new-indirect (param i32 i32) (result i32)))
12 … (import "" "thread.yield-to-suspended" (func $thread.yield-to-suspended (param i32) (result i32)))
13 (import "" "thread.yield" (func $thread.yield (result i32)))
30 (drop (call $thread.yield))
39 (core func $thread-new-indirect
41 (core func $thread-yield (canon thread.yield))
42 (core func $thread-yield-to-suspended (canon thread.yield-to-suspended))
46 (export "thread.new-indirect" (func $thread-new-indirect))
47 (export "thread.yield-to-suspended" (func $thread-yield-to-suspended))
[all …]
|
| H A D | stackful-cancellation.wast | 56 (import "" "thread.yield" (func $thread-yield (result i32)))
58 (import "" "thread.index" (func $thread-index (result i32)))
96 (call $thread-unsuspend (local.get $thread-index))
187 (core func $thread-yield (canon thread.yield))
189 (core func $thread-index (canon thread.index))
192 (core func $thread-unsuspend (canon thread.unsuspend))
195 (core func $thread-suspend (canon thread.suspend))
209 (export "thread.index" (func $thread-index))
212 (export "thread.yield" (func $thread-yield))
353 (core func $thread.yield (canon thread.yield))
[all …]
|
| /wasmtime-44.0.1/examples/ |
| H A D | threads.rs | 7 use std::thread;
24 println!("> Hello from {:?}", thread::current().id()); in main()
35 thread::spawn(move || { in main()
59 thread::sleep(time::Duration::from_millis(100)); in run()
63 println!("> Moving {:?} to a new thread", thread::current().id()); in run()
64 let child = thread::spawn(move || run.call(&mut store, ())); in run()
|
| H A D | threads.cc | 45 std::thread::id id = std::this_thread::get_id(); in run_worker()
54 std::thread::id id = std::this_thread::get_id(); in run_worker()
77 auto handle = std::thread([store = std::move(store), module]() mutable { in run_worker()
80 std::thread::id id = std::this_thread::get_id(); in run_worker()
97 std::vector<std::thread> threads; in main()
|
| H A D | interrupt.rs | 21 std::thread::spawn(move || { in main()
22 std::thread::sleep(std::time::Duration::from_secs(1)); in main()
|
| H A D | epochs.rs | 32 std::thread::spawn(move || { in main()
33 std::thread::sleep(std::time::Duration::from_secs(1)); in main()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/component/ |
| H A D | concurrent.rs | 1458 let instance = if let Some(thread) = thread.guest() { in enter_guest_sync_call()
1474 if let Some(thread) = thread.guest() { in enter_guest_sync_call()
1475 Caller::Guest { thread: *thread } in enter_guest_sync_call()
1521 thread, in exit_guest_sync_call()
1528 &Caller::Guest { thread } => thread.into(), in exit_guest_sync_call()
1629 Caller::Guest { thread } => thread.into(), in may_enter()
3334 let thread = state.get_mut(guest_thread.thread)?; in resume_thread() localVariable
3678 .get_mut(thread.thread)? in subtask_cancel()
4340 thread, in qualify()
5417 thread: QualifiedThreadId { task, thread }, in prepare_call()
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/ |
| H A D | parking_spot.rs | 20 use std::thread::{self, Thread};
43 thread: Thread, field
129 thread: thread::current(), in wait()
138 waiter.thread = thread::current(); in wait()
210 head.thread.unpark(); in notify()
316 use std::thread;
333 thread::scope(|s| { in atomic_wait_notify()
445 thread::scope(|s| { in run_parking_test()
598 thread::scope(|s| { in wait_with_timeout()
602 let thread = s.spawn(|| { in wait_with_timeout() localVariable
[all …]
|
| /wasmtime-44.0.1/tests/misc_testsuite/component-model/async/ |
| H A D | drop-host.wast | 16 (import "" "thread.yield" (func $thread.yield (result i32)))
21 (drop (call $thread.yield))
42 (core func $thread.yield (canon thread.yield))
47 (export "thread.yield" (func $thread.yield))
|
| H A D | yield-when-cancelled.wast | 10 (import "" "thread.yield" (func $thread-yield (result i32)))
17 (i32.ne (i32.const 0 (; NOT_CANCELLED ;) (call $thread-yield)))
42 (core func $thread-yield (canon thread.yield))
47 (export "thread.yield" (func $thread-yield))
|
| /wasmtime-44.0.1/cranelift/filetests/src/ |
| H A D | concurrent.rs | 14 use std::thread;
43 handles: Vec<thread::JoinHandle<timing::PassTimes>>,
116 fn heartbeat_thread(replies: Sender<Reply>) -> thread::JoinHandle<()> { in heartbeat_thread()
117 thread::Builder::new() in heartbeat_thread()
122 thread::sleep(Duration::from_secs(1)); in heartbeat_thread()
133 ) -> thread::JoinHandle<timing::PassTimes> { in worker_thread()
134 thread::Builder::new() in worker_thread()
|
| /wasmtime-44.0.1/tests/misc_testsuite/ |
| H A D | pooling-drop-out-of-order.wast | 1 ;; Small test case to create a module in one thread, drop another module in
2 ;; another thread, then drop the first module in the original thread. This
15 (thread $t1 (module (memory 1)))
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/sys/unix/ |
| H A D | machports.rs | 58 use std::thread;
67 thread: Option<thread::JoinHandle<()>>, field
82 let thread; in new() localVariable
99 thread = thread::spawn(|| handler_thread()); in new()
116 thread: Some(thread), in new()
126 self.thread.take().unwrap().join().unwrap(); in drop()
181 thread: mach_msg_port_descriptor_t, field
395 let origin_thread = request.body.thread.name; in handle_exception()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/ |
| H A D | profiling.rs | 80 thread: fxprof_processed_profile::ThreadHandle, field
162 let thread = profile.add_thread(process, 0, Timestamp::from_nanos_since_reference(0), true); in new() localVariable
169 thread, in new()
211 .intern_stack_frames(self.thread, frames.into_iter()); in sample()
213 .add_sample(self.thread, now, stack, delta.into(), 1); in sample()
230 self.thread, in call_hook()
236 .intern_stack_frames(self.thread, frames.into_iter()); in call_hook()
237 self.profile.set_marker_stack(self.thread, marker, stack); in call_hook()
241 .add_marker(self.thread, MarkerTiming::IntervalEnd(now), self.marker); in call_hook()
256 self.profile.set_thread_end_time(self.thread, now); in finish()
|
| /wasmtime-44.0.1/tests/misc_testsuite/threads/ |
| H A D | wait_notify.wast | 3 ;; test that looping notify eventually unblocks a parallel waiting thread
8 (thread $T1 (shared (module $Mem))
16 ;; test that this thread eventually gets unblocked
20 (thread $T2 (shared (module $Mem))
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | iloop.rs | 84 let thread = std::thread::spawn(move || { in loop_interrupt_from_afar() localVariable
97 thread.join().unwrap(); in loop_interrupt_from_afar()
121 let thread = std::thread::spawn(move || { in function_interrupt_from_afar() localVariable
133 thread.join().unwrap(); in function_interrupt_from_afar()
|
| H A D | wait_notify.rs | 73 let thread = { in atomic_wait_notify_basic() localVariable
77 std::thread::spawn(move || { in atomic_wait_notify_basic()
98 thread.join().unwrap(); in atomic_wait_notify_basic()
|
| H A D | threads.rs | 222 let thread = std::thread::spawn(move || { in test_grow_memory_in_multiple_threads() localVariable
233 std::thread::current().id(), in test_grow_memory_in_multiple_threads()
242 threads.push(thread); in test_grow_memory_in_multiple_threads()
287 let grow_thread = std::thread::spawn(move || { in test_memory_size_accessibility()
298 let probe_thread = std::thread::spawn(move || { in test_memory_size_accessibility()
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/ |
| H A D | sched.rs | 15 use std::thread;
30 thread::yield_now(); in sched_yield()
34 std::thread::sleep(duration); in sleep()
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/ |
| H A D | http_server.rs | 6 use std::thread::JoinHandle;
44 let thread = std::thread::spawn(|| -> Result<_> { in new() localVariable
55 let (rt, listener) = thread.join().unwrap()?; in new()
57 let worker = std::thread::spawn(move || { in new()
|
| /wasmtime-44.0.1/crates/fiber/src/ |
| H A D | miri.rs | 25 use std::thread::{self, JoinHandle};
63 thread: Option<JoinHandle<()>>, field
150 let thread = unsafe { in new() localVariable
151 thread::Builder::new() in new()
165 thread: Some(thread), in new()
204 self.thread.take().unwrap().join().unwrap(); in drop()
|
| /wasmtime-44.0.1/benches/ |
| H A D | thread_eager_init.rs | 2 use std::thread;
67 thread::spawn(move || duration_of_call(&engine, &module)) in lazy_thread_instantiate()
76 thread::spawn(move || { in eager_thread_instantiate()
|