Thanks for using Compiler Explorer
Sponsors
Jakt
C++
Ada
Analysis
Android Java
Android Kotlin
Assembly
C
C3
Carbon
C++ (Circle)
CIRCT
Clean
CMake
CMakeScript
COBOL
C++ for OpenCL
MLIR
Cppx
Cppx-Blue
Cppx-Gold
Cpp2-cppfront
Crystal
C#
CUDA C++
D
Dart
Elixir
Erlang
Fortran
F#
Go
Haskell
HLSL
Hook
Hylo
ispc
Java
Julia
Kotlin
LLVM IR
LLVM MIR
Modula-2
Nim
Objective-C
Objective-C++
OCaml
OpenCL C
Pascal
Pony
Python
Racket
Ruby
Rust
Snowball
Scala
Solidity
Spice
Swift
LLVM TableGen
Toit
TypeScript Native
V
Vala
Visual Basic
WASM
Zig
Javascript
GIMPLE
zig source #1
Output
Compile to binary object
Link to binary
Execute the code
Intel asm syntax
Demangle identifiers
Verbose demangling
Filters
Unused labels
Library functions
Directives
Comments
Horizontal whitespace
Debug intrinsics
Compiler
zig 0.10.0
zig 0.11.0
zig 0.12.0
zig 0.12.1
zig 0.13.0
zig 0.2.0
zig 0.3.0
zig 0.4.0
zig 0.5.0
zig 0.6.0
zig 0.7.0
zig 0.7.1
zig 0.8.0
zig 0.9.0
zig trunk
Options
Source code
const std = @import("std"); const expect = std.testing.expect; const assert = std.debug.assert; const time = std.time; const Timer = time.Timer; fn UnbufferedChannel(comptime T: type) type { return struct { const Self = @This(); value: ?T = null, waiting_recv: ?anyframe = null, waiting_send: ?anyframe = null, // Sends a value to the channel. // // Suspends until the value is fetched by a call to recv. pub fn send(self: *Self, t: T) void { assert(self.value == null); self.value = t; if (self.waiting_recv) |recv_op| { resume recv_op; } else { suspend { self.waiting_send = @frame(); } self.waiting_send = null; } } // Returns the value in the channel, or if there is no value present, // suspends until a value is sent into the channel. pub fn recv(self: *Self) T { if (self.value) |val| { self.value = null; assert(self.waiting_send != null); resume self.waiting_send.?; return val; } else { suspend { self.waiting_recv = @frame(); } self.waiting_recv = null; assert(self.waiting_send == null); assert(self.value != null); const val = self.value.?; self.value = null; return val; } } }; } fn test_unbuffered_channel_send_before_receive(finished_test: *bool) void { var channel = UnbufferedChannel(i32){}; const val = 1; var send_frame = async channel.send(val); var recv_frame = async channel.recv(); await send_frame; var received = await recv_frame; expect(val == received); finished_test.* = true; } fn test_unbuffered_channel_send_after_receive(finished_test: *bool) void { var channel = UnbufferedChannel(i32){}; const val = 1; var recv_frame = async channel.recv(); var send_frame = async channel.send(val); await send_frame; var received = await recv_frame; std.debug.print("received: {}\n", .{received}); expect(val == received); finished_test.* = true; } test "unbuffered channel send before receive" { var finished_test = false; _ = async test_unbuffered_channel_send_before_receive(&finished_test); expect(finished_test); } test "unbuffered channel send after receive" { var finished_test = false; _ = async test_unbuffered_channel_send_after_receive(&finished_test); expect(finished_test); } fn fibonacci_w_channel(channel: *UnbufferedChannel(i64)) void { var a: i64 = 0; var b: i64 = 1; while (true) { channel.send(b); const next = a + b; a = b; b = next; } } fn test_fibonacci_w_channel(finished_test: *bool) !void { var channel = UnbufferedChannel(i64){}; _ = async fibonacci_w_channel(&channel); try expect(channel.recv() == @intCast(i64, 1)); try expect(channel.recv() == @intCast(i64, 1)); try expect(channel.recv() == @intCast(i64, 2)); try expect(channel.recv() == @intCast(i64, 3)); try expect(channel.recv() == @intCast(i64, 5)); try expect(channel.recv() == @intCast(i64, 8)); try expect(channel.recv() == @intCast(i64, 13)); finished_test.* = true; } test "fibonacci w channel" { var finished_test = false; _ = async test_fibonacci_w_channel(&finished_test); expect(finished_test); } var test_frame: anyframe = undefined; fn fibonacci_w_channel_and_suspend(channel: *UnbufferedChannel(i64)) void { var a: i64 = 0; var b: i64 = 1; while (true) { suspend { test_frame = @frame(); } channel.send(b); const next = a + b; a = b; b = next; } } fn test_fibonacci_w_channel_and_suspend(finished_test: *bool) void { var channel = UnbufferedChannel(i64){}; _ = async fibonacci_w_channel_and_suspend(&channel); resume test_frame; expect(channel.recv() == @intCast(i64, 1)); resume test_frame; expect(channel.recv() == @intCast(i64, 1)); resume test_frame; expect(channel.recv() == @intCast(i64, 2)); resume test_frame; expect(channel.recv() == @intCast(i64, 3)); resume test_frame; expect(channel.recv() == @intCast(i64, 5)); resume test_frame; expect(channel.recv() == @intCast(i64, 8)); resume test_frame; expect(channel.recv() == @intCast(i64, 13)); finished_test.* = true; } pub fn main() !void { var finished_test = false; _ = async test_fibonacci_w_channel(&finished_test); try expect(finished_test); }
Become a Patron
Sponsor on GitHub
Donate via PayPal
Source on GitHub
Mailing list
Installed libraries
Wiki
Report an issue
How it works
Contact the author
CE on Mastodon
About the author
Statistics
Changelog
Version tree