Test_StaticPool_AllocateTimeout update

1 files changed, 10 insertions, 11 deletions

diff --git a/static_pool_test.go b/static_pool_test.go
index 565f4686..6cbd659e 100644
--- a/static_pool_test.go
+++ b/static_pool_test.go
@@ -219,7 +219,7 @@ func Test_StaticPool_AllocateTimeout(t *testing.T) {
 		NewPipeFactory(),
 		Config{
 			NumWorkers:      1,
-			AllocateTimeout: time.Nanosecond * 1,
+			AllocateTimeout: time.Millisecond * 50,
 			DestroyTimeout:  time.Second * 2,
 		},
 	)
@@ -228,26 +228,25 @@ func Test_StaticPool_AllocateTimeout(t *testing.T) {
 	}
 
 	done := make(chan interface{})
-
 	go func() {
 		if p != nil {
 			_, err := p.Exec(&Payload{Body: []byte("100")})
 			assert.NoError(t, err)
 			close(done)
 		} else {
-			panic("Pool is nil")
+			t.Fatal("Pool is nil")
 		}
+	}()
 
-		// to ensure that worker is already busy
-		time.Sleep(time.Millisecond * 100)
 
-		_, err = p.Exec(&Payload{Body: []byte("10")})
-		if err == nil {
-			t.Fatal("Test_StaticPool_AllocateTimeout exec should raise error")
-		}
-		assert.Contains(t, err.Error(), "worker timeout")
-	}()
+	// to ensure that worker is already busy
+	time.Sleep(time.Millisecond * 10)
 
+	_, err = p.Exec(&Payload{Body: []byte("10")})
+	if err == nil {
+		t.Fatal("Test_StaticPool_AllocateTimeout exec should raise error")
+	}
+	assert.Contains(t, err.Error(), "worker timeout")
 
 	<-done
 	p.Destroy()