mirror of
https://github.com/hibiken/asynq.git
synced 2024-12-24 23:02:18 +08:00
Fix test for base package
This commit is contained in:
parent
eef2f5f3cb
commit
c688b8f4f9
@ -106,9 +106,9 @@ func TestWorkersKey(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Test for process state being accessed by multiple goroutines.
|
// Test for server state being accessed by multiple goroutines.
|
||||||
// Run with -race flag to check for data race.
|
// Run with -race flag to check for data race.
|
||||||
func TestProcessStateConcurrentAccess(t *testing.T) {
|
func TestServerStateConcurrentAccess(t *testing.T) {
|
||||||
ss := NewServerState("127.0.0.1", 1234, 10, map[string]int{"default": 1}, false)
|
ss := NewServerState("127.0.0.1", 1234, 10, map[string]int{"default": 1}, false)
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
started := time.Now()
|
started := time.Now()
|
||||||
@ -124,6 +124,9 @@ func TestProcessStateConcurrentAccess(t *testing.T) {
|
|||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
ss.SetStarted(started)
|
ss.SetStarted(started)
|
||||||
ss.SetStatus(StatusRunning)
|
ss.SetStatus(StatusRunning)
|
||||||
|
if status := ss.Status(); status != StatusRunning {
|
||||||
|
t.Errorf("(*ServerState).Status() = %v, want %v", status, StatusRunning)
|
||||||
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
// Simulate processor starting worker goroutines.
|
// Simulate processor starting worker goroutines.
|
||||||
|
Loading…
Reference in New Issue
Block a user