Update

Author: devlights

examples/singleapp/count_down_latch/countdownlatch.go

@@ -69,18 +69,3 @@ func (me *CountdownLatch) CurrentCount() int {
 
 	return int(me.count.Load())
 }
-
-// Reset は、カウントを指定された値にリセットします.
-// リセットすることになるため、強制的にカウント満了したことになり、待機している非同期処理が存在する場合は解除されます.
-func (me *CountdownLatch) Reset(count int) {
-	if count < 0 {
-		panic("リセットカウントは0以上である必要があります")
-	}
-
-	me.mutex.Lock()
-	defer me.mutex.Unlock()
-
-	me.cond.Broadcast()
-
-	me.count.Store(int32(count))
-}

examples/singleapp/count_down_latch/main.go

@@ -70,30 +70,25 @@ func proc(_ context.Context) error {
 		wg    sync.WaitGroup
 	)
 
-	for range 2 {
-		latch.Reset(latchCount)
-
-		for i := range 5 {
-			wg.Add(1)
-			go func(i int) {
-				defer wg.Done()
-
-				log.Printf("[%2d] 待機開始", i)
-				latch.Wait()
-				log.Printf("[%2d] 待機解除", i)
-			}(i)
-		}
+	for i := range 5 {
+		wg.Add(1)
+		go func(i int) {
+			defer wg.Done()
+
+			log.Printf("[%2d] 待機開始", i)
+			latch.Wait()
+			log.Printf("[%2d] 待機解除", i)
+		}(i)
+	}
 
-		for range 3 {
-			<-time.After(time.Second)
+	for range 3 {
+		<-time.After(time.Second)
 
-			log.Printf("現在のカウント: %d\n", latch.CurrentCount())
-			latch.Signal()
-		}
-
-		wg.Wait()
-		log.Println("-------------------------------------")
+		log.Printf("現在のカウント: %d\n", latch.CurrentCount())
+		latch.Signal()
 	}
 
+	wg.Wait()
+
 	return nil
 }