aboutsummaryrefslogtreecommitdiff
path: root/src/thread_pool.zig
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <jarred@jarredsumner.com> 2021-11-27 01:12:58 -0800
committerGravatar Jarred Sumner <jarred@jarredsumner.com> 2021-12-16 19:18:51 -0800
commit809c1e46d8c7a144156e5f6d8ad89351b5f7d740 (patch)
tree9b56e67442c8632d85b0f07641ab949334b637fa /src/thread_pool.zig
parentc0560931255c0d303df7478b1778c0e54759f010 (diff)
downloadbun-809c1e46d8c7a144156e5f6d8ad89351b5f7d740.tar.gz
bun-809c1e46d8c7a144156e5f6d8ad89351b5f7d740.tar.zst
bun-809c1e46d8c7a144156e5f6d8ad89351b5f7d740.zip
[npm install] starting to look good!
Diffstat (limited to 'src/thread_pool.zig')
-rw-r--r--src/thread_pool.zig13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/thread_pool.zig b/src/thread_pool.zig
index 74c0032cc..8b171c422 100644
--- a/src/thread_pool.zig
+++ b/src/thread_pool.zig
@@ -240,14 +240,13 @@ noinline fn wait(self: *ThreadPool, _is_waking: bool) error{Shutdown}!bool {
}
} else {
if (self.io) |io| {
- while (true) {
- io.run_for_ns(std.time.ns_per_ms * 500) catch {};
- const sync2 = @bitCast(Sync, self.sync.load(.Monotonic));
- if (sync2.state != sync.state) {
- sync = @bitCast(Sync, self.sync.load(.Monotonic));
- continue;
- }
+ const HTTP = @import("./http/http_client_async.zig");
+ io.run_for_ns(std.time.ns_per_us * 100) catch {};
+ while (HTTP.AsyncHTTP.active_requests_count.load(.Monotonic) > 100) {
+ io.tick() catch {};
}
+ sync = @bitCast(Sync, self.sync.load(.Monotonic));
+ continue;
}
self.idle_event.wait();