wood/webp_server_go
1
0
Fork 0
mirror of https://github.com/woodchen-ink/webp_server_go.git synced 2025-07-18 13:42:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

prefetch custom cores, -jobs=3

Browse Source
This commit is contained in:
Benny~ 2020-03-03 19:50:06 +08:00
parent c0f5368319
commit f4a1bad454
No known key found for this signature in database
GPG Key ID: 6CD0DBDA5235D481
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
webp-server.go
View File

@ -39,6 +39,7 @@ const version = "0.0.3"
var configPath string var configPath string
var prefetch bool var prefetch bool
var jobs int
var dumpConfig bool var dumpConfig bool
var dumpSystemd bool var dumpSystemd bool
@ -159,6 +160,7 @@ func webpEncoder(p1, p2 string, quality float32, Log bool, c chan int) (err erro
func init() { func init() {
flag.StringVar(&configPath, "config", "config.json", "/path/to/config.json. (Default: ./config.json)") flag.StringVar(&configPath, "config", "config.json", "/path/to/config.json. (Default: ./config.json)")
flag.BoolVar(&prefetch, "prefetch", false, "Prefetch and convert image to webp") flag.BoolVar(&prefetch, "prefetch", false, "Prefetch and convert image to webp")
flag.IntVar(&jobs, "jobs", runtime.NumCPU(), "Prefetch thread, default is all.")
flag.BoolVar(&dumpConfig, "dump-config", false, "Print sample config.json") flag.BoolVar(&dumpConfig, "dump-config", false, "Print sample config.json")
flag.BoolVar(&dumpSystemd, "dump-systemd", false, "Print sample systemd service file.") flag.BoolVar(&dumpSystemd, "dump-systemd", false, "Print sample systemd service file.")
flag.Parse() flag.Parse()
@ -278,8 +280,9 @@ func prefetchImages(confImgPath string, ExhaustPath string, QUALITY string) {
reader := bufio.NewReader(os.Stdin) reader := bufio.NewReader(os.Stdin)
char, _, _ := reader.ReadRune() //y Y enter char, _, _ := reader.ReadRune() //y Y enter
// maximum ongoing prefetch is depending on your core of CPU // maximum ongoing prefetch is depending on your core of CPU
var finishChan = make(chan int, runtime.NumCPU()) log.Printf("Prefetching using %d cores", jobs)
for i := 0; i < runtime.NumCPU(); i++ { var finishChan = make(chan int, jobs)
for i := 0; i < jobs; i++ {
finishChan <- 0 finishChan <- 0
} }
if char == 121 || char == 10 || char == 89 { if char == 121 || char == 10 || char == 89 {