chore: code cleanup

pool.go

@@ -194,9 +194,9 @@ func NewPool(size int, options ...Option) (*Pool, error) {
 		if size == -1 {
 			return nil, ErrInvalidPreAllocSize
 		}
-		p.workers = newWorkerArray(queueTypeLoopQueue, size)
+		p.workers = newWorkerQueue(queueTypeLoopQueue, size)
 	} else {
-		p.workers = newWorkerArray(queueTypeStack, 0)
+		p.workers = newWorkerQueue(queueTypeStack, 0)
 	}
 
 	p.cond = sync.NewCond(p.lock)

pool_func.go

@@ -200,9 +200,9 @@ func NewPoolWithFunc(size int, pf func(interface{}), options ...Option) (*PoolWi
 		if size == -1 {
 			return nil, ErrInvalidPreAllocSize
 		}
-		p.workers = newWorkerArray(queueTypeLoopQueue, size)
+		p.workers = newWorkerQueue(queueTypeLoopQueue, size)
 	} else {
-		p.workers = newWorkerArray(queueTypeStack, 0)
+		p.workers = newWorkerQueue(queueTypeStack, 0)
 	}
 
 	p.cond = sync.NewCond(p.lock)

worker_loop_queue_test.go

@@ -49,7 +49,7 @@ func TestLoopQueue(t *testing.T) {
 	assert.EqualValuesf(t, 6, q.len(), "Len error: %d", q.len())
 }
 
-func TestRotatedArraySearch(t *testing.T) {
+func TestRotatedQueueSearch(t *testing.T) {
 	size := 10
 	q := newWorkerLoopQueue(size)
 

worker_queue.go

@@ -37,7 +37,7 @@ const (
 	queueTypeLoopQueue
 )
 
-func newWorkerArray(qType queueType, size int) workerQueue {
+func newWorkerQueue(qType queueType, size int) workerQueue {
 	switch qType {
 	case queueTypeStack:
 		return newWorkerStack(size)

worker_stack_test.go

@@ -19,7 +19,7 @@ func TestNewWorkerStack(t *testing.T) {
 }
 
 func TestWorkerStack(t *testing.T) {
-	q := newWorkerArray(queueType(-1), 0)
+	q := newWorkerQueue(queueType(-1), 0)
 
 	for i := 0; i < 5; i++ {
 		err := q.insert(&goWorker{lastUsed: time.Now()})