Function generateCommits

commit.go:26–106

(commits map[string]git.Commit, params Params)

)

func generateCommits(commits map[string]git.Commit, params Params) error {
	outDir := filepath.Join(params.OutputDir, "commit")
	if err := os.MkdirAll(outDir, 0o755); err != nil {
		return err
	}

	list := make([]git.Commit, 0, len(commits))
	for _, c := range commits {
		list = append(list, c)
	}

	workers := runtime.NumCPU()
	if workers < 1 {
		workers = 1
	}

	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	jobs := make(chan git.Commit)
	errCh := make(chan error, 1)
	var wg sync.WaitGroup

	p := progress_bar.NewProgressBar("commits", len(list))

	workerFn := func() {
		defer wg.Done()
		for {
			select {
			case <-ctx.Done():
				return
			case c, ok := <-jobs:
				if !ok {
					return
				}
				if err := generateCommitPage(c, params); err != nil {
					select {
					case errCh <- err:
						cancel()
					default:
					}
					return
				}
				p.Inc()
			}
		}
	}

	wg.Add(workers)
	for i := 0; i < workers; i++ {
		go workerFn()
	}

	go func() {
		defer close(jobs)
		for _, c := range list {
			select {
			case <-ctx.Done():