Merge pull request #5 from pharosnet/dev

Dev
pharosnet · Apr 28, 2018 · e5b8b05 · e5b8b05
2 parents da2bdfd + 5de6cda
commit e5b8b05
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 5 deletions.
diff --git a/README.md b/README.md
@@ -11,7 +11,7 @@ A flyline buffer works similar to a standard Go channel with the following featu
 
 ### Installing
 
-To start using fastlane, install Go and run `go get`:
+To start using flyline, install Go and run `go get`:
 
 ```sh
 $ go get github.com/pharosnet/flyline

diff --git a/array.go b/array.go
@@ -6,7 +6,8 @@ import (
 )
 
 type entry struct {
-	value interface{}
+	value   interface{}
+	padding [7]int64
 }
 
 func newArray(capacity int64) (a *array) {

diff --git a/array_buffer.go b/array_buffer.go
@@ -51,7 +51,7 @@ func (b *arrayBuffer) Send(i interface{}) (err error) {
 			b.wdSeq.Incr()
 			break
 		}
-		time.Sleep(500 * time.Microsecond)
+		time.Sleep(1 * time.Nanosecond)
 		if times <= 0 {
 			runtime.Gosched()
 			times = 10
@@ -74,7 +74,7 @@ func (b *arrayBuffer) Recv() (value interface{}, active bool) {
 			b.rdSeq.Incr()
 			break
 		}
-		time.Sleep(500 * time.Microsecond)
+		time.Sleep(1 * time.Nanosecond)
 		if times <= 0 {
 			runtime.Gosched()
 			times = 10

diff --git a/sequence.go b/sequence.go
@@ -1,8 +1,9 @@
 package flyline
 
 import (
-	"runtime"
 	"sync/atomic"
+	"runtime"
+	"time"
 )
 
 // Sequence New Function, value starts from -1.
@@ -29,6 +30,7 @@ func (s *Sequence) Incr() (value int64) {
 			value = nextValue
 			break
 		}
+		time.Sleep(1 * time.Nanosecond)
 		if times <= 0 {
 			times = 10
 			runtime.Gosched()
@@ -48,6 +50,7 @@ func (s *Sequence) Decr() (value int64) {
 			value = preValue
 			break
 		}
+		time.Sleep(1 * time.Nanosecond)
 		if times <= 0 {
 			times = 10
 			runtime.Gosched()