aboutsummaryrefslogtreecommitdiff
path: root/src/napi/napi.zig
diff options
context:
space:
mode:
authorGravatar Dylan Conway <35280289+dylan-conway@users.noreply.github.com> 2023-09-06 02:04:00 -0700
committerGravatar GitHub <noreply@github.com> 2023-09-06 02:04:00 -0700
commitdaaac7792cc348030d64a33087f1a41b3a3822cf (patch)
tree6a1e2415a50b9bf6cf5516b6ee4fa1121ae8fba4 /src/napi/napi.zig
parent7c82dc86baf3b01600b66d77737b2766ece83b03 (diff)
downloadbun-daaac7792cc348030d64a33087f1a41b3a3822cf.tar.gz
bun-daaac7792cc348030d64a33087f1a41b3a3822cf.tar.zst
bun-daaac7792cc348030d64a33087f1a41b3a3822cf.zip
allocate task for `ThreadSafeFunction` (#4513)
* create thread safe function task * Update napi.zig * Update napi.zig
Diffstat (limited to '')
-rw-r--r--src/napi/napi.zig6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/napi/napi.zig b/src/napi/napi.zig
index 1d3e3e811..d143fe1b3 100644
--- a/src/napi/napi.zig
+++ b/src/napi/napi.zig
@@ -1215,8 +1215,6 @@ pub const ThreadSafeFunction = struct {
owning_threads: std.AutoArrayHashMapUnmanaged(u64, void) = .{},
owning_thread_lock: Lock = Lock.init(),
event_loop: *JSC.EventLoop,
- concurrent_task: JSC.ConcurrentTask = .{},
- concurrent_finalizer_task: JSC.ConcurrentTask = .{},
env: napi_env,
@@ -1323,7 +1321,7 @@ pub const ThreadSafeFunction = struct {
}
}
- this.event_loop.enqueueTaskConcurrent(this.concurrent_task.from(this, .manual_deinit));
+ this.event_loop.enqueueTaskConcurrent(JSC.ConcurrentTask.createFrom(this));
}
pub fn finalize(opaq: *anyopaque) void {
@@ -1372,7 +1370,7 @@ pub const ThreadSafeFunction = struct {
if (this.owning_threads.count() == 0) {
this.finalizer_task = JSC.AnyTask{ .ctx = this, .callback = finalize };
- this.event_loop.enqueueTaskConcurrent(this.concurrent_finalizer_task.from(&this.finalizer_task, .manual_deinit));
+ this.event_loop.enqueueTaskConcurrent(JSC.ConcurrentTask.fromCallback(this, finalize));
return;
}
}