fix: remove useless scheduler.Start()

WangYihang · Feb 27, 2024 · 26e2a78 · 26e2a78
1 parent ea56b62
commit 26e2a78
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/examples/complex-http-crawler/main.go b/examples/complex-http-crawler/main.go
@@ -41,6 +41,5 @@ func main() {
 	for line := range util.Cat(opts.InputFilePath) {
 		scheduler.Submit(model.New(string(line)))
 	}
-	scheduler.Start()
 	scheduler.Wait()
 }
diff --git a/examples/sleeper/main.go b/examples/sleeper/main.go
@@ -32,7 +32,6 @@ func main() {
 		SetNumShards(4).
 		SetShard(0).
 		Start()
-	scheduler.Start()
 	for i := 0; i < 256; i++ {
 		scheduler.Submit(New(i, rand.Intn(10)))
 	}