Method Run

core/pool/brutepool.go:203–299

(offset, limit int)

}

func (pool *BrutePool) Run(offset, limit int) {
	pool.Worder.Run()
	if pool.Active {
		pool.launchProducer(pool.doActive)
	}

	if pool.Bak {
		pool.launchProducer(pool.doBak)
	}

	if pool.Fuzzuli {
		pool.launchProducer(pool.doFuzzuli)
	}

	if pool.Common {
		pool.launchProducer(pool.doCommonFile)
	}

	// worderCh 指向 Worder 输出; 设为 nil 后 select 不再接受新词,
	// 随后 allDone 等待 in-flight 工作全部结束再退出循环.
	// 这比 atomic.Bool + 轮询 monitor goroutine 更安全: wg.Add 只发生在
	// worderCh 分支, nil 掉之后不会再有新 Add, 消除了 Add/Wait 竞态.
	worderCh := pool.Worder.Output
	var allDone <-chan struct{} // nil channel: select 永远不选中

	var drainOnce sync.Once
	startDrain := func() {
		drainOnce.Do(func() {
			worderCh = nil
			ch := make(chan struct{})
			go func() { pool.wg.Wait(); close(ch) }()
			allDone = ch
		})
	}

Loop:
	for {
		select {
		case w, ok := <-worderCh:
			if !ok {
				startDrain()
				continue
			}
			pool.Statistor.End++

			wordOffset := int(pool.wordOffset.Add(1))
			if wordOffset < offset {
				continue
			}

			if pool.Statistor.End > limit {
				startDrain()
				continue
			}

			if w == "" {
				pool.Statistor.Skipped++
				pool.Bar.Done()