update queue size

vearne · Jul 11, 2024 · 4927d47 · 4927d47
1 parent feb76cc
commit 4927d47
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/internal/command/grpc_automate.go b/internal/command/grpc_automate.go
@@ -58,7 +58,7 @@ func HandleSingleFileGrpc(workerNum int, filePath string) (*ResultInfo, []GrpcTe
 	testcases := resource.GrpcTestCases[filePath]
 	slog.Info("[start]HandleSingleFileGrpc, filePath:%v, len(testcase):%v", filePath, len(testcases))
 
-	futureChan := make(chan executor.Future, 10)
+	futureChan := make(chan executor.Future, len(testcases))
 	pool := executor.NewFixedGPool(context.Background(), workerNum)
 	defer pool.WaitTerminate()
 

diff --git a/internal/command/http_automate.go b/internal/command/http_automate.go
@@ -87,7 +87,7 @@ func HandleSingleFileHttp(workerNum int, filePath string) (*ResultInfo, []HttpTe
 	testcases := resource.HttpTestCases[filePath]
 	slog.Info("[start]HandleSingleFileHttp, filePath:%v, len(testcase):%v", filePath, len(testcases))
 
-	futureChan := make(chan executor.Future, 10)
+	futureChan := make(chan executor.Future, len(testcases))
 	pool := executor.NewFixedGPool(context.Background(), workerNum)
 	defer pool.WaitTerminate()
 

diff --git a/main.go b/main.go
@@ -11,7 +11,7 @@ import (
 )
 
 const (
-	version = "v0.1.0"
+	version = "v0.1.1"
 )
 
 func main() {
-Original file line number
+Diff line change
@@ Expand Up / @@ -11,7 +11,7 @@ import ( @@
     )
     const (
-    	version = "v0.1.0"
+    	version = "v0.1.1"
     )
     func main() {
@@ Expand Down @@