mirrors/Odin
1
0
Fork 0
mirror of https://github.com/odin-lang/Odin.git synced 2026-02-12 06:18:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

chan: fix example and deadlock on closed channel

Browse Source
This commit is contained in:
Laytan Laats
2026-01-11 20:10:02 +01:00
parent 6c663b7a71
commit b9946aa67e
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
core/sync/chan/chan.odin
View File

@@ -1166,7 +1166,7 @@ Example:
import "core:sync/chan"
import "core:fmt"
select_raw_example :: proc() {
try_select_raw_example :: proc() {
c, err := chan.create(chan.Chan(int), 1, context.allocator)
assert(err == .None)
defer chan.destroy(c)
@@ -1198,11 +1198,11 @@ Example:
Output:
SELECT: 0 true
SELECT: 0 Send
RECEIVED VALUE 0
SELECT: 0 true
SELECT: 0 Recv
RECEIVED VALUE 1
SELECT: 0 false
SELECT: -1 None
*/
@(require_results)
@@ -1219,7 +1219,7 @@ try_select_raw :: proc "odin" (recvs: []^Raw_Chan, sends: []^Raw_Chan, send_msgs
count := 0
for c, i in recvs {
if can_recv(c) {
if !c.closed && can_recv(c) {
candidates[count] = {
is_recv = true,
idx = i,
@@ -1232,7 +1232,7 @@ try_select_raw :: proc "odin" (recvs: []^Raw_Chan, sends: []^Raw_Chan, send_msgs
if i > builtin.len(send_msgs)-1 || send_msgs[i] == nil {
continue
}
if can_send(c) {
if !c.closed && can_send(c) {
candidates[count] = {
is_recv = false,
idx = i,