Skip to content

Commit 4b86fb6

Browse files
fix: concurrency
1 parent af47f4a commit 4b86fb6

File tree

2 files changed

+9
-5
lines changed

2 files changed

+9
-5
lines changed

pkg/jatt.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,9 +33,6 @@ func NewJatt(cfg config.JattConfig) *Jatt {
3333
func (j *Jatt) Run() {
3434
timeStart := time.Now()
3535

36-
j.wg.Add(1)
37-
go j.writer.CopyStatic(&j.wg)
38-
3936
files := j.reader.Read()
4037
renderedFiles := j.renderer.Render(files)
4138

@@ -48,7 +45,12 @@ func (j *Jatt) Run() {
4845

4946
j.wg.Wait()
5047

51-
j.writer.WriteRSSFeed(feed)
48+
j.wg.Add(1)
49+
go j.writer.CopyStatic(&j.wg)
50+
j.wg.Add(1)
51+
go j.writer.WriteRSSFeed(&j.wg, feed)
52+
53+
j.wg.Wait()
5254

5355
timeEnd := time.Now()
5456
fmt.Println(styles.StatsStyle.Render(fmt.Sprintf("\n⚡Took %v", timeEnd.Sub(timeStart).Round(time.Millisecond))))

pkg/writer/writer.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,9 @@ func (w *Writer) CopyStatic(wg *sync.WaitGroup) error {
112112
return nil
113113
}
114114

115-
func (w *Writer) WriteRSSFeed(feed []byte) {
115+
func (w *Writer) WriteRSSFeed(wg *sync.WaitGroup, feed []byte) {
116+
defer wg.Done()
117+
116118
outputDir := w.cfg.SiteConfig.OutputDir
117119
err := os.WriteFile(outputDir+"/rss.xml", feed, 0644)
118120
if err != nil {

0 commit comments

Comments
 (0)