fumiama/zbpdata
1
0
Fork 0
mirror of https://github.com/FloatTech/zbpdata.git synced 2024-11-17 17:47:14 +09:00
Code

fix: push

Browse Source
This commit is contained in:
源文雨 2022-05-04 20:26:05 +08:00
parent 6df0a6f70b
commit f2fa48b3d7
1 changed files with 17 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
main.go
View File

@ -10,11 +10,9 @@ import (
"io/fs" "io/fs"
"os" "os"
"strings" "strings"
"sync"
"unicode" "unicode"
"unsafe" "unsafe"
"github.com/FloatTech/zbputils/process"
"github.com/fumiama/go-registry" "github.com/fumiama/go-registry"
"github.com/wdvxdr1123/ZeroBot/utils/helper" "github.com/wdvxdr1123/ZeroBot/utils/helper"
) )
@ -46,12 +44,7 @@ func main() {
if err != nil { if err != nil {
panic(err) panic(err)
} }
defer r.Close()
var wg sync.WaitGroup
wg.Add(len(files))
for i, fn := range files { for i, fn := range files {
go func(i int, fn string) {
defer wg.Done()
for c := 0; c < 5; c++ { for c := 0; c < 5; c++ {
err = r.Set("data/"+fn, md5s[i]) err = r.Set("data/"+fn, md5s[i])
fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i]))) fmt.Println("set", "data/"+fn, "=", hex.EncodeToString(helper.StringToBytes(md5s[i])))
@ -63,9 +56,12 @@ func main() {
} else { } else {
fmt.Println("ERROR:", err, ", retry times:", c) fmt.Println("ERROR:", err, ", retry times:", c)
} }
process.SleepAbout1sTo2s() _ = r.Close()
err = r.Connect()
if err != nil {
panic(err)
} }
}(i, fn)
} }
wg.Wait() }
_ = r.Close()
} }