Merge pull request #16 from alitto/feature/1.6.0

Upgrade to go v1.17

.travis.yml

@@ -12,6 +12,7 @@ go:
   - 1.14.x
   - 1.15.x
   - 1.16.x
+  - 1.17.x
 
 # Enable Go Modules
 env:

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

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

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

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

go.mod

@@ -1,3 +1,3 @@
 module github.com/alitto/pond
 
-go 1.16
+go 1.17

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()