1 files changed, 47 insertions, 1 deletions

diff --git a/core/benches/op_baseline.rs b/core/benches/op_baseline.rs
index 9c288fe27..dd1499c9f 100644
--- a/core/benches/op_baseline.rs
+++ b/core/benches/op_baseline.rs
@@ -1,16 +1,24 @@
 use bencher::{benchmark_group, benchmark_main, Bencher};
 
 use deno_core::bin_op_sync;
+use deno_core::error::AnyError;
+use deno_core::json_op_async;
 use deno_core::json_op_sync;
 use deno_core::v8;
+use deno_core::BufVec;
 use deno_core::JsRuntime;
 use deno_core::Op;
 use deno_core::OpResponse;
+use deno_core::OpState;
+
+use std::cell::RefCell;
+use std::rc::Rc;
 
 fn create_js_runtime() -> JsRuntime {
   let mut runtime = JsRuntime::new(Default::default());
   runtime.register_op("pi_bin", bin_op_sync(|_, _, _| Ok(314159)));
   runtime.register_op("pi_json", json_op_sync(|_, _: (), _| Ok(314159)));
+  runtime.register_op("pi_async", json_op_async(op_pi_async));
   runtime
     .register_op("nop", |_, _, _| Op::Sync(OpResponse::Value(Box::new(9))));
 
@@ -30,6 +38,15 @@ fn create_js_runtime() -> JsRuntime {
   runtime
 }
 
+// this is a function since async closures aren't stable
+async fn op_pi_async(
+  _: Rc<RefCell<OpState>>,
+  _: (),
+  _: BufVec,
+) -> Result<i64, AnyError> {
+  Ok(314159)
+}
+
 pub fn bench_runtime_js(b: &mut Bencher, src: &str) {
   let mut runtime = create_js_runtime();
   let context = runtime.global_context();
@@ -41,6 +58,20 @@ pub fn bench_runtime_js(b: &mut Bencher, src: &str) {
   });
 }
 
+pub fn bench_runtime_js_async(b: &mut Bencher, src: &str) {
+  let mut runtime = create_js_runtime();
+  let tokio_runtime = tokio::runtime::Builder::new_current_thread()
+    .enable_all()
+    .build()
+    .unwrap();
+
+  b.iter(|| {
+    runtime.execute("inner_loop", src).unwrap();
+    let future = runtime.run_event_loop();
+    tokio_runtime.block_on(future).unwrap();
+  });
+}
+
 fn bench_op_pi_bin(b: &mut Bencher) {
   bench_runtime_js(
     b,
@@ -68,5 +99,20 @@ fn bench_op_nop(b: &mut Bencher) {
   );
 }
 
-benchmark_group!(benches, bench_op_pi_bin, bench_op_pi_json, bench_op_nop);
+fn bench_op_async(b: &mut Bencher) {
+  bench_runtime_js_async(
+    b,
+    r#"for(let i=0; i < 1e3; i++) {
+      Deno.core.jsonOpAsync("pi_async", null);
+    }"#,
+  );
+}
+
+benchmark_group!(
+  benches,
+  bench_op_pi_bin,
+  bench_op_pi_json,
+  bench_op_nop,
+  bench_op_async
+);
 benchmark_main!(benches);