re
/
ants
forked from mirror/ants
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update example codes of integrating with http server

This commit is contained in:
Andy Pan 2018-12-03 14:31:49 +08:00
parent 6a62b85079
commit 2093372461
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -119,7 +119,7 @@ func main() {
pool, _ := ants.NewPoolWithFunc(100, func(payload interface{}) {
request, ok := payload.(*Request)
if !ok {
request = Request{Param:[]byte(""), Result: make(chan []byte)}
return
}
reverseParam := func(s []byte) []byte {
for i, j := 0, len(s)-1; i < j; i, j = i+1, j-1 {

2
README_ZH.md
View File

@ -118,7 +118,7 @@ func main() {
pool, _ := ants.NewPoolWithFunc(100, func(payload interface{}) {
request, ok := payload.(*Request)
if !ok {
request = Request{Param:[]byte(""), Result: make(chan []byte)}
return
}
reverseParam := func(s []byte) []byte {
for i, j := 0, len(s)-1; i < j; i, j = i+1, j-1 {

1
ants_test.go
View File

@ -71,6 +71,7 @@ func TestAntsPoolWithFunc(t *testing.T) {
curMem = mem.TotalAlloc/MiB - curMem
t.Logf("memory usage:%d MB", curMem)
}
func TestNoPool(t *testing.T) {
var wg sync.WaitGroup
for i := 0; i < n; i++ {