channel bug fix

2024-11-22 02:12:39 +01:00 · 2018-04-04 13:00:46 +03:00 · 2018-04-04 13:00:46 +03:00 · 35928128f6
commit 35928128f6
parent 3d3cf765fc
1 changed files with 3 additions and 0 deletions
--- a/b2q.go
+++ b/b2q.go
@ -317,6 +317,9 @@ func main() {
 	for message := range comChannel {
 		fmt.Printf("%v/%v %v \n", numjob, totaljobs, message)
 		numjob++
+		if numjob == totaljobs {
+			break
+		}
 	}
 	fmt.Println("\nPress Enter to exit")
 	fmt.Scanln()