From 4b4b6c574b64fa1f259c36db11ea3339183a2e0a Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期一, 28 十月 2019 13:48:52 +0800
Subject: [PATCH] test
---
EsApi.go | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index 61aa641..179c75d 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -358,12 +358,12 @@
"\"_source\":[\"id\"]" +
"}"
wg.Add(1)
- go func() {
+ go func(reqParam string) {
defer wg.Done()
//fmt.Println(url)
//fmt.Println(prama)
- buf, err := EsReq("POST", url, []byte(prama))
+ buf, err := EsReq("POST", url, []byte(reqParam))
if err != nil {
fmt.Println("http request videoUrlInfo info is err!")
@@ -378,7 +378,9 @@
return
}
for _, source := range sources["sourcelist"].([]map[string]interface{}) {
+ lock.Lock()
capturetable = append(capturetable, source["id"].(string))
+ lock.Unlock()
}
scroll_id := sources["scroll_id"].(string)
@@ -428,7 +430,7 @@
next_scroll_id = nextSources["scroll_id"].(string)
}
- }()
+ }(prama)
}
wg.Wait()
--
Gitblit v1.8.0