GetCount get the node count
()
| 145 | |
| 146 | // GetCount get the node count |
| 147 | func (q *Queue) GetCount() int64 { |
| 148 | q.mux.Lock() |
| 149 | defer q.mux.Unlock() |
| 150 | |
| 151 | return q.count |
| 152 | } |
| 153 | |
| 154 | // GetCount get the node count in query and only return zero when working zero |
| 155 | func (q *Queue) GetCountWithWorkingBlock() int64 { |