root
/
m3u8d
mirror of https://gitee.com/zhang_1334717033/m3u8d.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

多线程未开启bug修复 https://github.com/orestonce/m3u8d/issues/6

main v1.5.16
orestonce 2022-08-30 08:45:18 +08:00
parent a46b8388c7
commit 912f62c5a4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
download.go
View File

@ -291,7 +291,7 @@ func RunDownload(req RunDownload_Req) (resp RunDownload_Resp) {
Proxy: http.ProxyURL(proxyUrlObj), Proxy: http.ProxyURL(proxyUrlObj),
}, },
}, },
speedBytesMap: map[time.Time]int64{}, speedBytesMap: map[time.Time]int64{},
progressBarShow: req.ProgressBarShow, progressBarShow: req.ProgressBarShow,
} }
env.ctx, env.cancelFn = context.WithCancel(context.Background()) env.ctx, env.cancelFn = context.WithCancel(context.Background())
@ -448,7 +448,7 @@ func (this *downloadEnv) SleepDur(d time.Duration) {
} }
func (this *downloadEnv) downloader(tsList []TsInfo, downloadDir string, key string) (err error) { func (this *downloadEnv) downloader(tsList []TsInfo, downloadDir string, key string) (err error) {
task := gopool.NewThreadPool(1) task := gopool.NewThreadPool(8)
tsLen := len(tsList) tsLen := len(tsList)
downloadCount := 0 downloadCount := 0
var locker sync.Mutex var locker sync.Mutex