Commit 29a3a03

committed

Add --thread option (default 10)

Limit the concurrent wait groups to avoid too many open files

1 parent d4926af commit 29a3a03Copy full SHA for 29a3a03

File tree

1 file changed

-3

lines changed

main.go

1 file changed

-3

lines changed

`‎main.go‎`

Lines changed: 4 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,6 @@ package main`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"fmt"`
`5`		`- "sync"`
`6`	`5`	`"errors"`
`7`	`6`	`"bytes"`
`8`	`7`	`"io/ioutil"`
`@@ -11,6 +10,7 @@ import (`
`11`	`10`	`"strings"`
`12`	`11`	`"regexp"`
`13`	`12`	`flags "github.com/jessevdk/go-flags"`
	`13`	`+ "github.com/remeh/sizedwaitgroup"`
`14`	`14`	`)`
`15`	`15`
`16`	`16`	`const (`
`@@ -38,6 +38,7 @@ type fileitem struct {`
`38`	`38`	`}`
`39`	`39`
`40`	`40`	`var opts struct {`
	`41`	+ ThreadCount int ` long:"threads" description:"Set thread concurrency for replacing in multiple files at same time" default:"10"`
`41`	`42`	Mode string `short:"m" long:"mode" description:"replacement mode - replace: replace match with term; line: replace line with term; lineinfile: replace line with term or if not found append to term to file; template: parse content as golang template, search value have to start uppercase" default:"replace" choice:"replace" choice:"line" choice:"lineinfile" choice:"template"`
`42`	`43`	`ModeIsReplaceMatch bool`
`43`	`44`	`ModeIsReplaceLine bool`
`@@ -347,11 +348,11 @@ func actionProcessFiles(changesets []changeset, fileitems []fileitem) (int) {`
`347`	`348`
`348`	`349`	`results := make(chan changeresult)`
`349`	`350`
`350`		`- varwg sync.WaitGroup`
	`351`	`+ wg :=sizedwaitgroup.New(opts.ThreadCount)`
`351`	`352`
`352`	`353`	`// process file list`
`353`	`354`	`for _, file := range fileitems {`
`354`		`- wg.Add(1)`
	`355`	`+ wg.Add()`
`355`	`356`	`go func(file fileitem, changesets []changeset) {`
`356`	`357`	`var (`
`357`	`358`	`err error = nil`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit 29a3a03

File tree

1 file changed

1 file changed

`‎main.go‎`

0 commit comments