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
use jni::objects::JValue; use jni::sys; use jni::NativeMethod; use super::{Env, Reference}; pub struct Thread { reference: Reference, } struct ThreadClosure(Box<dyn FnOnce(&Env) + Send>); impl Thread { pub fn new<F>(env: &Env, closure: F) -> Thread where F: FnOnce(&Env) + Send + 'static, { extern "C" fn main(env: *mut sys::JNIEnv, _: sys::jobject, data: i64) { unsafe { let closure = Box::<ThreadClosure>::from_raw(data as *mut _); closure.0(&Env::new(env)); } } unsafe { env.register_natives( "com/glacyr/polyhorn/PolyhornThread", vec![NativeMethod { name: "main".to_owned().into(), sig: "(J)V".to_owned().into(), fn_ptr: main as *mut _, }], ); let closure = Box::new(ThreadClosure(Box::new(closure))); Thread { reference: env.retain(env.call_constructor( "com/glacyr/polyhorn/PolyhornThread", "(J)V", &[JValue::Long(Box::into_raw(closure) as i64)], )), } } } pub fn start(self, env: &Env) { unsafe { env.call_method(self.reference.as_object(), "start", "()V", &[]); } } }