Skip to content

Commit 58821e9

Browse files
authored
mailbox worker to write directly to receiveC if there is space in buffer (#64)
1 parent 719c583 commit 58821e9

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

actor/mailbox.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,12 @@ func (w *mailboxWorker[T]) DoWork(c Context) WorkerStatus {
207207
return WorkerEnd
208208

209209
case value := <-w.sendC:
210-
w.queue.PushBack(value)
210+
if len(w.receiveC) < mbxChanBufferCap {
211+
w.receiveC <- value
212+
} else {
213+
w.queue.PushBack(value)
214+
}
215+
211216
return WorkerContinue
212217
}
213218
}

0 commit comments

Comments
 (0)