commitquery/queries_acquire.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

package commitquery

func (queries *Queries) acquire() *query {
	queries.mu.Lock()
	defer queries.mu.Unlock()

	count := len(queries.idle)
	if count == 0 {
		return newQuery(queries.store, queries.graph)
	}

	q := queries.idle[count-1]
	queries.idle = queries.idle[:count-1]

	return q
}