lobo/FlexiLib
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

thread pool based on environment variable with cpu count fallback

Browse Source
This commit is contained in:
Emil Lerch 2023-06-03 08:57:47 -07:00
parent eaef2c6ddc
commit 626a2e618c
Signed by: lobo
GPG Key ID: A7B62D657EF764F8
1 changed files with 23 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/main.zig
View File

@ -8,7 +8,11 @@ const log = std.log.scoped(.main);
// logging options // logging options
pub const std_options = struct { pub const std_options = struct {
pub const log_level = .debug; pub const log_level = switch (builtin.mode) {
.Debug => .debug,
.ReleaseSafe => .info,
.ReleaseFast, .ReleaseSmall => .err,
};
pub const log_scope_levels = &[_]std.log.ScopeLevel{ pub const log_scope_levels = &[_]std.log.ScopeLevel{
.{ .scope = .watch, .level = .info }, .{ .scope = .watch, .level = .info },
@ -365,28 +369,33 @@ pub fn main() !void {
log.info("pid: {d}", .{std.os.linux.getpid()}); log.info("pid: {d}", .{std.os.linux.getpid()});
try installSignalHandler(); try installSignalHandler();
var server_thread_count = if (std.os.getenv("SERVER_THREAD_COUNT")) |count|
try std.fmt.parseInt(usize, count, 10)
else
try std.Thread.getCpuCount();
log.info("serving using {d} threads", .{server_thread_count});
var server_threads = try std.ArrayList(std.Thread).initCapacity(allocator, server_thread_count);
defer server_threads.deinit();
// Set up thread pool // Set up thread pool
const server_thread = try std.Thread.spawn( for (0..server_thread_count) |inx| {
.{}, server_threads.appendAssumeCapacity(try std.Thread.spawn(
threadMain, .{},
.{ allocator, &server }, threadMain,
); .{ allocator, &server, inx },
const server_thread2 = try std.Thread.spawn( ));
.{}, }
threadMain,
.{ allocator, &server },
);
// main thread will no longer do anything // main thread will no longer do anything
std.time.sleep(std.math.maxInt(u64)); std.time.sleep(std.math.maxInt(u64));
server_thread.join(); for (server_threads.items) |thread| thread.join();
server_thread2.join();
} }
fn threadMain(allocator: std.mem.Allocator, server: *std.http.Server) !void { fn threadMain(allocator: std.mem.Allocator, server: *std.http.Server, thread_number: usize) !void {
// TODO: If we're in a thread pool we need to be careful with this... // TODO: If we're in a thread pool we need to be careful with this...
const stdout_file = std.io.getStdOut().writer(); const stdout_file = std.io.getStdOut().writer();
var bw = std.io.bufferedWriter(stdout_file); var bw = std.io.bufferedWriter(stdout_file);
const stdout = bw.writer(); const stdout = bw.writer();
log.info("starting server thread {d}, tid {d}", .{ thread_number, std.Thread.getCurrentId() });
var arena = std.heap.ArenaAllocator.init(allocator); var arena = std.heap.ArenaAllocator.init(allocator);
defer arena.deinit(); defer arena.deinit();
var aa = arena.allocator(); var aa = arena.allocator();