Implement chain style Setters for BufferedChannelQueue.

Author: johnteee

README.md

@@ -200,9 +200,10 @@ var err error
 var result interface{}
 var timeout time.Duration
 
-bufferedChannelQueue := NewBufferedChannelQueue(3, 10000, 100)
-bufferedChannelQueue.SetLoadFromPoolDuration(time.Millisecond / 10)
-bufferedChannelQueue.SetFreeNodeHookPoolIntervalDuration(1 * time.Millisecond)
+bufferedChannelQueue := NewBufferedChannelQueue(3, 10000, 100).
+  SetLoadFromPoolDuration(time.Millisecond / 10).
+  SetFreeNodeHookPoolIntervalDuration(1 * time.Millisecond)
+
 
 err = queue.Offer(1)
 err = queue.Offer(2)

queue.go

@@ -577,23 +577,27 @@ func (q *BufferedChannelQueue) notifyWorkers() {
 }
 
 // SetBufferSizeMaximum Set MaximumBufferSize(maximum number of buffered items outside the ChannelQueue)
-func (q *BufferedChannelQueue) SetBufferSizeMaximum(size int) {
+func (q *BufferedChannelQueue) SetBufferSizeMaximum(size int) *BufferedChannelQueue {
 	q.bufferSizeMaximum = size
+	return q
 }
 
 // SetNodeHookPoolSize Set nodeHookPoolSize(the buffering node hooks ideal size)
-func (q *BufferedChannelQueue) SetNodeHookPoolSize(size int) {
+func (q *BufferedChannelQueue) SetNodeHookPoolSize(size int) *BufferedChannelQueue {
 	q.nodeHookPoolSize = size
+	return q
 }
 
 // SetLoadFromPoolDuration Set loadFromPoolDuration(the interval to take buffered items into the ChannelQueue)
-func (q *BufferedChannelQueue) SetLoadFromPoolDuration(duration time.Duration) {
+func (q *BufferedChannelQueue) SetLoadFromPoolDuration(duration time.Duration) *BufferedChannelQueue {
 	q.loadFromPoolDuration = duration
+	return q
 }
 
 // SetFreeNodeHookPoolIntervalDuration Set freeNodeHookPoolIntervalDuration(the interval to clear buffering node hooks down to nodeHookPoolSize)
-func (q *BufferedChannelQueue) SetFreeNodeHookPoolIntervalDuration(duration time.Duration) {
+func (q *BufferedChannelQueue) SetFreeNodeHookPoolIntervalDuration(duration time.Duration) *BufferedChannelQueue {
 	q.freeNodeHookPoolIntervalDuration = duration
+	return q
 }
 
 // Close Close the Handler

queue_test.go

@@ -263,9 +263,9 @@ func TestNewBufferedChannelQueue(t *testing.T) {
 	var result interface{}
 	var timeout time.Duration
 
-	bufferedChannelQueue := NewBufferedChannelQueue(3, 10000, 100)
-	bufferedChannelQueue.SetLoadFromPoolDuration(time.Millisecond / 10)
-	bufferedChannelQueue.SetFreeNodeHookPoolIntervalDuration(1 * time.Millisecond)
+	bufferedChannelQueue := NewBufferedChannelQueue(3, 10000, 100).
+		SetLoadFromPoolDuration(time.Millisecond / 10).
+		SetFreeNodeHookPoolIntervalDuration(1 * time.Millisecond)
 	queue = bufferedChannelQueue
 
 	// Sync