Merge pull request #16 from alitto/feature/1.6.0

Upgrade to go v1.17
alitto · Nov 20, 2021 · a646d99 · a646d99
2 parents a8db74f + fc8bba0
commit a646d99
Show file tree

Hide file tree

Showing 7 changed files with 10 additions and 9 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -12,6 +12,7 @@ go:
   - 1.14.x
   - 1.15.x
   - 1.16.x
+  - 1.17.x
 
 # Enable Go Modules
 env:

diff --git a/examples/dynamic_size/go.mod b/examples/dynamic_size/go.mod
@@ -1,6 +1,6 @@
 module github.com/alitto/pond/examples/dynamic_size
 
-go 1.16
+go 1.17
 
 require (
 	github.com/alitto/pond v1.5.1

diff --git a/examples/fixed_size/go.mod b/examples/fixed_size/go.mod
@@ -1,6 +1,6 @@
 module github.com/alitto/pond/examples/fixed_size
 
-go 1.16
+go 1.17
 
 require (
 	github.com/alitto/pond v1.5.1

diff --git a/examples/prometheus/go.mod b/examples/prometheus/go.mod
@@ -1,6 +1,6 @@
 module github.com/alitto/pond/examples/fixed_size
 
-go 1.16
+go 1.17
 
 require (
 	github.com/alitto/pond v1.5.1

diff --git a/examples/task_group/go.mod b/examples/task_group/go.mod
@@ -1,6 +1,6 @@
 module github.com/alitto/pond/examples/task_group
 
-go 1.16
+go 1.17
 
 require (
 	github.com/alitto/pond v1.5.1

diff --git a/go.mod b/go.mod
@@ -1,3 +1,3 @@
 module github.com/alitto/pond
 
-go 1.16
+go 1.17
diff --git a/pond_blackbox_test.go b/pond_blackbox_test.go
@@ -141,16 +141,16 @@ func TestSubmitBefore(t *testing.T) {
 
 	// Submit a long-running task
 	var doneCount int32
-	pool.SubmitBefore(func() {
-		time.Sleep(5 * time.Millisecond)
+	pool.Submit(func() {
+		time.Sleep(50 * time.Millisecond)
 		atomic.AddInt32(&doneCount, 1)
-	}, 1*time.Millisecond)
+	})
 
 	// Submit a task that times out after 2ms
 	pool.SubmitBefore(func() {
 		time.Sleep(5 * time.Millisecond)
 		atomic.AddInt32(&doneCount, 1)
-	}, 2*time.Millisecond)
+	}, 5*time.Millisecond)
 
 	pool.StopAndWait()