Update base/channels.jl

Co-authored-by: Takafumi Arakaki <[email protected]>
JuliaLang · Nov 6, 2021 · c203a3f · c203a3f
1 parent ac0a4ae
commit c203a3f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/base/channels.jl b/base/channels.jl
@@ -344,6 +344,8 @@ function put_buffered(c::Channel, v)
         # notify all, since some of the waiters may be on a "fetch" call.
         notify(c.cond_take, nothing, true, false)
     finally
+        # Decrement the available items if this task had an exception before pushing the
+        # item to the buffer (e.g., during `wait(c.cond_put)`):
         did_buffer || _increment_n_avail(c, -1)
         unlock(c)
     end