diff options
Diffstat (limited to 'std/atomic/queue.zig')
| -rw-r--r-- | std/atomic/queue.zig | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/std/atomic/queue.zig b/std/atomic/queue.zig index e1cadf5d1c..c0c050f0ba 100644 --- a/std/atomic/queue.zig +++ b/std/atomic/queue.zig @@ -7,7 +7,7 @@ const assert = std.debug.assert; /// Many producer, many consumer, non-allocating, thread-safe. /// Uses a mutex to protect access. pub fn Queue(comptime T: type) type { - return struct { + return struct.{ head: ?*Node, tail: ?*Node, mutex: std.Mutex, @@ -16,7 +16,7 @@ pub fn Queue(comptime T: type) type { pub const Node = std.LinkedList(T).Node; pub fn init() Self { - return Self{ + return Self.{ .head = null, .tail = null, .mutex = std.Mutex.init(), @@ -126,7 +126,7 @@ pub fn Queue(comptime T: type) type { }; } -const Context = struct { +const Context = struct.{ allocator: *std.mem.Allocator, queue: *Queue(i32), put_sum: isize, @@ -154,7 +154,7 @@ test "std.atomic.Queue" { var a = &fixed_buffer_allocator.allocator; var queue = Queue(i32).init(); - var context = Context{ + var context = Context.{ .allocator = a, .queue = &queue, .put_sum = 0, @@ -198,7 +198,7 @@ fn startPuts(ctx: *Context) u8 { while (put_count != 0) : (put_count -= 1) { std.os.time.sleep(1); // let the os scheduler be our fuzz const x = @bitCast(i32, r.random.scalar(u32)); - const node = ctx.allocator.create(Queue(i32).Node{ + const node = ctx.allocator.create(Queue(i32).Node.{ .prev = undefined, .next = undefined, .data = x, @@ -226,14 +226,14 @@ fn startGets(ctx: *Context) u8 { test "std.atomic.Queue single-threaded" { var queue = Queue(i32).init(); - var node_0 = Queue(i32).Node{ + var node_0 = Queue(i32).Node.{ .data = 0, .next = undefined, .prev = undefined, }; queue.put(&node_0); - var node_1 = Queue(i32).Node{ + var node_1 = Queue(i32).Node.{ .data = 1, .next = undefined, .prev = undefined, @@ -242,14 +242,14 @@ test "std.atomic.Queue single-threaded" { assert(queue.get().?.data == 0); - var node_2 = Queue(i32).Node{ + var node_2 = Queue(i32).Node.{ .data = 2, .next = undefined, .prev = undefined, }; queue.put(&node_2); - var node_3 = Queue(i32).Node{ + var node_3 = Queue(i32).Node.{ .data = 3, .next = undefined, .prev = undefined, @@ -260,7 +260,7 @@ test "std.atomic.Queue single-threaded" { assert(queue.get().?.data == 2); - var node_4 = Queue(i32).Node{ + var node_4 = Queue(i32).Node.{ .data = 4, .next = undefined, .prev = undefined, |
