aboutsummaryrefslogtreecommitdiff
path: root/std/atomic/queue.zig
diff options
context:
space:
mode:
authorhryx <codroid@gmail.com>2019-05-27 17:24:21 -0700
committerhryx <codroid@gmail.com>2019-05-27 17:24:21 -0700
commite1f3eec9cc05535b3f3b81f2fb7cd65dd4d1e841 (patch)
tree5f408ed68a686491eaf759f9cbba02beac829b38 /std/atomic/queue.zig
parent2aa1c5da5dded6b1b346c3a1b57443f2c459ebe9 (diff)
parent3fccc0747903f0726d6cc8ee73832cb62f1304bb (diff)
downloadzig-e1f3eec9cc05535b3f3b81f2fb7cd65dd4d1e841.tar.gz
zig-e1f3eec9cc05535b3f3b81f2fb7cd65dd4d1e841.zip
Merge branch 'master' into translate-c-userland
Diffstat (limited to 'std/atomic/queue.zig')
-rw-r--r--std/atomic/queue.zig12
1 files changed, 6 insertions, 6 deletions
diff --git a/std/atomic/queue.zig b/std/atomic/queue.zig
index 431a96e64b..bf5700c51e 100644
--- a/std/atomic/queue.zig
+++ b/std/atomic/queue.zig
@@ -186,13 +186,13 @@ test "std.atomic.Queue" {
}
}
} else {
- var putters: [put_thread_count]*std.os.Thread = undefined;
+ var putters: [put_thread_count]*std.Thread = undefined;
for (putters) |*t| {
- t.* = try std.os.spawnThread(&context, startPuts);
+ t.* = try std.Thread.spawn(&context, startPuts);
}
- var getters: [put_thread_count]*std.os.Thread = undefined;
+ var getters: [put_thread_count]*std.Thread = undefined;
for (getters) |*t| {
- t.* = try std.os.spawnThread(&context, startGets);
+ t.* = try std.Thread.spawn(&context, startGets);
}
for (putters) |t|
@@ -220,7 +220,7 @@ fn startPuts(ctx: *Context) u8 {
var put_count: usize = puts_per_thread;
var r = std.rand.DefaultPrng.init(0xdeadbeef);
while (put_count != 0) : (put_count -= 1) {
- std.os.time.sleep(1); // let the os scheduler be our fuzz
+ std.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) catch unreachable;
node.* = Queue(i32).Node{
@@ -239,7 +239,7 @@ fn startGets(ctx: *Context) u8 {
const last = @atomicLoad(u8, &ctx.puts_done, builtin.AtomicOrder.SeqCst) == 1;
while (ctx.queue.get()) |node| {
- std.os.time.sleep(1); // let the os scheduler be our fuzz
+ std.time.sleep(1); // let the os scheduler be our fuzz
_ = @atomicRmw(isize, &ctx.get_sum, builtin.AtomicRmwOp.Add, node.data, builtin.AtomicOrder.SeqCst);
_ = @atomicRmw(usize, &ctx.get_count, builtin.AtomicRmwOp.Add, 1, builtin.AtomicOrder.SeqCst);
}