You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Nov 10, 2020. It is now read-only.
@cloudzhou Regarding your first question: The variable naming is a little bit demanding to be honest but pcond is the PRODUCER condition. So what the code correctly does is it gains exclusive PRODUCER access and then notifies the CONSUMERS about new data.
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
I hava some confusions, delete this issue if I make it wrong.
1 code: https://github.com/surgemq/surgemq/blob/master/service/buffer.go#L121-L123
is:
this.pcond.L.Lock()
this.ccond.Broadcast()
this.pcond.L.Unlock()
or just:
this.ccond.L.Lock()
this.ccond.Broadcast()
this.ccond.L.Unlock()
?
2 https://github.com/surgemq/surgemq/blob/master/topics/memtopics.go#L30-L48
why there are two same lines:
var _ TopicsProvider = (*memTopics)(nil)
Appreciate!
The text was updated successfully, but these errors were encountered: