@@ -52,9 +52,9 @@ const (
5252
5353type (
5454 slot [T any ] struct {
55- State uint32
56- WriteParker * ThreadParker [T ]
57- Item T
55+ state uint32
56+ writeParker * ThreadParker [T ]
57+ item T
5858 }
5959
6060 selectFactory struct {
@@ -101,7 +101,7 @@ func New[T any](size uint32) *ZenQ[T] {
101101 for idx := uint32 (0 ); idx < queueSize ; idx ++ {
102102 n := parkPool .Get ().(* parkSpot [T ])
103103 n .threadPtr , n .next = nil , nil
104- contents [idx ].WriteParker = NewThreadParker [T ](unsafe .Pointer (n ))
104+ contents [idx ].writeParker = NewThreadParker [T ](unsafe .Pointer (n ))
105105 }
106106 zenq := & ZenQ [T ]{
107107 strideLength : unsafe .Sizeof (slot [T ]{}),
@@ -153,14 +153,14 @@ direct_send:
153153 slot := (* slot [T ])(unsafe .Pointer (uintptr (atomic .AddUint32 (& self .writerIndex , 1 )& self .indexMask )* self .strideLength + uintptr (self .contents )))
154154
155155 // CAS -> change slot_state to busy if slot_state == empty
156- for ! atomic .CompareAndSwapUint32 (& slot .State , SlotEmpty , SlotBusy ) {
157- switch atomic .LoadUint32 (& slot .State ) {
156+ for ! atomic .CompareAndSwapUint32 (& slot .state , SlotEmpty , SlotBusy ) {
157+ switch atomic .LoadUint32 (& slot .state ) {
158158 case SlotBusy :
159159 wait ()
160160 case SlotCommitted :
161161 n := self .alloc ().(* parkSpot [T ])
162162 n .threadPtr , n .next , n .value = GetG (), nil , value
163- slot .WriteParker .Park (unsafe .Pointer (n ))
163+ slot .writeParker .Park (unsafe .Pointer (n ))
164164 mcall (fast_park )
165165 return
166166 case SlotEmpty :
@@ -169,8 +169,8 @@ direct_send:
169169 return
170170 }
171171 }
172- slot .Item = value
173- atomic .StoreUint32 (& slot .State , SlotCommitted )
172+ slot .item = value
173+ atomic .StoreUint32 (& slot .state , SlotCommitted )
174174 return
175175}
176176
@@ -179,13 +179,13 @@ func (self *ZenQ[T]) Read() (data T, queueOpen bool) {
179179 slot := (* slot [T ])(unsafe .Pointer (uintptr (atomic .AddUint32 (& self .readerIndex , 1 )& self .indexMask )* self .strideLength + uintptr (self .contents )))
180180
181181 // CAS -> change slot_state to busy if slot_state == committed
182- for ! atomic .CompareAndSwapUint32 (& slot .State , SlotCommitted , SlotBusy ) {
183- switch atomic .LoadUint32 (& slot .State ) {
182+ for ! atomic .CompareAndSwapUint32 (& slot .state , SlotCommitted , SlotBusy ) {
183+ switch atomic .LoadUint32 (& slot .state ) {
184184 case SlotBusy :
185185 wait ()
186186 case SlotEmpty :
187187 var freeable * parkSpot [T ]
188- if data , queueOpen , freeable = slot .WriteParker .Ready (); queueOpen {
188+ if data , queueOpen , freeable = slot .writeParker .Ready (); queueOpen {
189189 if freeable != nil {
190190 self .free (freeable )
191191 }
@@ -199,7 +199,7 @@ func (self *ZenQ[T]) Read() (data T, queueOpen bool) {
199199 return
200200 }
201201 case SlotClosed :
202- if atomic .CompareAndSwapUint32 (& slot .State , SlotClosed , SlotEmpty ) {
202+ if atomic .CompareAndSwapUint32 (& slot .state , SlotClosed , SlotEmpty ) {
203203 atomic .StoreUint32 (& self .globalState , StateFullyClosed )
204204 }
205205 queueOpen = false
@@ -208,8 +208,8 @@ func (self *ZenQ[T]) Read() (data T, queueOpen bool) {
208208 continue
209209 }
210210 }
211- data , queueOpen = slot .Item , true
212- atomic .StoreUint32 (& slot .State , SlotEmpty )
211+ data , queueOpen = slot .item , true
212+ atomic .StoreUint32 (& slot .state , SlotEmpty )
213213 return
214214}
215215
@@ -228,8 +228,8 @@ func (self *ZenQ[T]) Close() (alreadyClosedForWrites bool) {
228228 slot := (* slot [T ])(unsafe .Pointer (uintptr (atomic .AddUint32 (& self .writerIndex , 1 )& self .indexMask )* self .strideLength + uintptr (self .contents )))
229229
230230 // CAS -> change slot_state to busy if slot_state == empty
231- for ! atomic .CompareAndSwapUint32 (& slot .State , SlotEmpty , SlotBusy ) {
232- switch atomic .LoadUint32 (& slot .State ) {
231+ for ! atomic .CompareAndSwapUint32 (& slot .state , SlotEmpty , SlotBusy ) {
232+ switch atomic .LoadUint32 (& slot .state ) {
233233 case SlotBusy , SlotCommitted :
234234 mcall (gosched_m )
235235 case SlotEmpty :
@@ -239,7 +239,7 @@ func (self *ZenQ[T]) Close() (alreadyClosedForWrites bool) {
239239 }
240240 }
241241 // Closing commit
242- atomic .StoreUint32 (& slot .State , SlotClosed )
242+ atomic .StoreUint32 (& slot .state , SlotClosed )
243243 return
244244}
245245
@@ -293,9 +293,10 @@ func (self *ZenQ[T]) Reset() {
293293// Unsafe to be called from multiple goroutines
294294func (self * ZenQ [T ]) Dump () {
295295 fmt .Printf ("writerIndex: %3d, readerIndex: %3d\n contents:-\n \n " , self .writerIndex , self .readerIndex )
296- // for idx := range self.contents {
297- // fmt.Printf("%5v : State -> %5v, Item -> %5v\n", idx, self.contents[idx].State, self.contents[idx].Item)
298- // }
296+ for idx := uintptr (0 ); idx <= uintptr (self .indexMask ); idx ++ {
297+ slot := (* slot [T ])(unsafe .Pointer (uintptr (self .contents ) + idx * unsafe .Sizeof (slot [T ]{})))
298+ fmt .Printf ("Slot -> %#v\n " , * slot )
299+ }
299300}
300301
301302// selectSender is an auxillary thread which remains parked by default
0 commit comments