a277cf5ee4
This commit updates `wasmtime::FuncType` to exactly store an internal `WasmFuncType` from the cranelift crates. This allows us to remove a translation layer when we are given a `FuncType` and want to get an internal cranelift type out as a result. The other major change from this commit was changing the constructor and accessors of `FuncType` to be iterator-based instead of exposing implementation details.
67 lines
1.7 KiB
Rust
67 lines
1.7 KiB
Rust
// You can execute this example with `cargo run --example threads`
|
|
|
|
use anyhow::{format_err, Result};
|
|
use std::thread;
|
|
use std::time;
|
|
use wasmtime::*;
|
|
|
|
const N_THREADS: i32 = 10;
|
|
const N_REPS: i32 = 3;
|
|
|
|
fn run(engine: &Engine, module: Module, id: i32) -> Result<()> {
|
|
let store = Store::new(&engine);
|
|
|
|
// Create external print functions.
|
|
println!("Creating callback...");
|
|
let callback_func = Func::wrap(&store, |arg: i32| {
|
|
println!("> Thread {} is running", arg);
|
|
});
|
|
|
|
let id_type = GlobalType::new(ValType::I32, Mutability::Const);
|
|
let id_global = Global::new(&store, id_type, Val::I32(id))?;
|
|
|
|
// Instantiate.
|
|
println!("Instantiating module...");
|
|
let instance = Instance::new(&store, &module, &[callback_func.into(), id_global.into()])?;
|
|
|
|
// Extract exports.
|
|
println!("Extracting export...");
|
|
let g = instance
|
|
.get_func("run")
|
|
.ok_or(format_err!("failed to find export `eun`"))?;
|
|
|
|
for _ in 0..N_REPS {
|
|
thread::sleep(time::Duration::from_millis(100));
|
|
// Call `$run`.
|
|
drop(g.call(&[])?);
|
|
}
|
|
|
|
Ok(())
|
|
}
|
|
|
|
fn main() -> Result<()> {
|
|
println!("Initializing...");
|
|
let engine = Engine::default();
|
|
|
|
// Compile.
|
|
println!("Compiling module...");
|
|
let module = Module::from_file(&engine, "examples/threads.wat")?;
|
|
|
|
let mut children = Vec::new();
|
|
for id in 0..N_THREADS {
|
|
let engine = engine.clone();
|
|
let module = module.clone();
|
|
children.push(thread::spawn(move || {
|
|
run(&engine, module, id).expect("Success");
|
|
}));
|
|
}
|
|
|
|
for (i, child) in children.into_iter().enumerate() {
|
|
if let Err(_) = child.join() {
|
|
println!("Thread #{} errors", i);
|
|
}
|
|
}
|
|
|
|
Ok(())
|
|
}
|