- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for TestExecuteDelayed (0.24 sec)
-
pkg/controller/tainteviction/timed_workers_test.go
queue.AddWork(context.TODO(), NewWorkArgs("5", "5"), now, now) wg.Wait() lastVal := atomic.LoadInt32(&testVal) if lastVal != 5 { t.Errorf("Expected testVal = 5, got %v", lastVal) } } func TestExecuteDelayed(t *testing.T) { testVal := int32(0) wg := sync.WaitGroup{} wg.Add(5) queue := CreateWorkerQueue(func(ctx context.Context, fireAt time.Time, args *WorkArgs) error { atomic.AddInt32(&testVal, 1) wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 5.6K bytes - Viewed (0)