diff options
author | 2021-11-27 01:12:58 -0800 | |
---|---|---|
committer | 2021-12-16 19:18:51 -0800 | |
commit | 809c1e46d8c7a144156e5f6d8ad89351b5f7d740 (patch) | |
tree | 9b56e67442c8632d85b0f07641ab949334b637fa /src/thread_pool.zig | |
parent | c0560931255c0d303df7478b1778c0e54759f010 (diff) | |
download | bun-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.zig | 13 |
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(); |