change new function name and implement

container/queue/poolqueue.go

@@ -205,8 +205,8 @@ func (d *poolDequeue) PopTail() (interface{}, bool) {
 	return val, true
 }
 
-// NewPoolDequeue new a poolDequeue instance.
-func NewPoolDequeue(n int) (*poolDequeue, error) {
+// NewSPMCLockFreeQ new a poolDequeue instance.
+func NewSPMCLockFreeQ(n int) (SPMCLockFreeQ, error) {
 	if n&(n-1) != 0 {
 		return nil, errors.New("the size of pool must be a power of 2")
 	}

container/queue/poolqueue_test.go

@@ -23,27 +23,25 @@ import (
 	"sync"
 	"sync/atomic"
 	"testing"
-)
 
-import (
 	"github.com/stretchr/testify/assert"
 )
 
 func TestCreatePoolDequeue(t *testing.T) {
-	_, err := NewPoolDequeue(15)
+	_, err := NewSPMCLockFreeQ(15)
 	assert.EqualError(t, err, "the size of pool must be a power of 2")
-	_, err = NewPoolDequeue(18)
+	_, err = NewSPMCLockFreeQ(18)
 	assert.EqualError(t, err, "the size of pool must be a power of 2")
-	_, err = NewPoolDequeue(24)
+	_, err = NewSPMCLockFreeQ(24)
 	assert.EqualError(t, err, "the size of pool must be a power of 2")
-	_, err = NewPoolDequeue(8)
+	_, err = NewSPMCLockFreeQ(8)
 	assert.NoError(t, err)
 }
 
 func TestPoolDequeue(t *testing.T) {
 	const P = 10
 	var N int = 2e6
-	d, err := NewPoolDequeue(16)
+	d, err := NewSPMCLockFreeQ(16)
 	if err != nil {
 		t.Errorf("create poolDequeue fail")
 	}