55
func (c *ConditionVariableImpl) Wait(
56
interrupt <-chan struct{},
58
>
59
>
c.chanLock.Lock()
60
>
channel := c.channel
61
>
c.chanLock.Unlock()
62
>
63
>
// user provided lock must be released after getting the above channel
64
>
// so channel to be waited on < release of user lock < acquire of user lock < signal / broadcast
65
>
// ```
66
>
// That is, if another thread is able to acquire the mutex after the about-to-block
67
>
// thread has released it, then a subsequent call to pthread_cond_signal() or
68
>
// pthread_cond_broadcast() in that thread behaves as if it were issued after the
69
>
// about-to-block thread has blocked.
70
>
// ref: https://pubs.opengroup.org/onlinepubs/007908799/xsh/pthread_cond_wait.html
71
>
// ```
72
>
73
>
c.lock.Unlock()
74
>
defer c.lock.Lock()
75
>
76
>
select {
77
case <-channel:
78
// received signal