diff --git a/worker_stack_test.go b/worker_stack_test.go index 5a55663..93d04f5 100644 --- a/worker_stack_test.go +++ b/worker_stack_test.go @@ -1,3 +1,5 @@ +// +build !windows + package ants import ( @@ -9,15 +11,15 @@ func TestNewWorkerStack(t *testing.T) { size := 100 q := newWorkerStack(size) if q.len() != 0 { - t.Fatalf("Len error") + t.Fatal("Len error") } if !q.isEmpty() { - t.Fatalf("IsEmpty error") + t.Fatal("IsEmpty error") } if q.detach() != nil { - t.Fatalf("Dequeue error") + t.Fatal("Dequeue error") } } @@ -31,14 +33,14 @@ func TestWorkerStack(t *testing.T) { } } if q.len() != 5 { - t.Fatalf("Len error") + t.Fatal("Len error") } expired := time.Now() err := q.insert(&goWorker{recycleTime: expired}) if err != nil { - t.Fatalf("Enqueue error") + t.Fatal("Enqueue error") } time.Sleep(time.Second) @@ -46,21 +48,23 @@ func TestWorkerStack(t *testing.T) { for i := 0; i < 6; i++ { err := q.insert(&goWorker{recycleTime: time.Now()}) if err != nil { - t.Fatalf("Enqueue error") + t.Fatal("Enqueue error") } } if q.len() != 12 { - t.Fatalf("Len error") + t.Fatal("Len error") } q.retrieveExpiry(time.Second) if q.len() != 6 { - t.Fatalf("Len error") + t.Fatal("Len error") } } +// It seems that something wrong with time.Now() on Windows, not sure whether it is a bug on Windows, so exclude this test +// from Windows platform temporarily. func TestSearch(t *testing.T) { q := newWorkerStack(0) @@ -71,12 +75,12 @@ func TestSearch(t *testing.T) { index := q.binarySearch(0, q.len()-1, time.Now()) if index != 0 { - t.Fatalf("should is 0") + t.Fatal("index should be 0") } index = q.binarySearch(0, q.len()-1, expiry1) if index != -1 { - t.Fatalf("should is -1") + t.Fatal("index should be -1") } // 2 @@ -85,17 +89,17 @@ func TestSearch(t *testing.T) { index = q.binarySearch(0, q.len()-1, expiry1) if index != -1 { - t.Fatalf("should is -1") + t.Fatal("index should be -1") } index = q.binarySearch(0, q.len()-1, expiry2) if index != 0 { - t.Fatalf("should is 0") + t.Fatal("index should be 0") } index = q.binarySearch(0, q.len()-1, time.Now()) if index != 1 { - t.Fatalf("should is 1") + t.Fatal("index should be 1") } // more @@ -113,6 +117,6 @@ func TestSearch(t *testing.T) { index = q.binarySearch(0, q.len()-1, expiry3) if index != 7 { - t.Fatalf("should is 7") + t.Fatal("index should be 7") } }