```go
package main

import (
"fmt"
"net/http"
"time"

"github.com/gin-contrib/gzip"
"github.com/gin-gonic/gin"
)

func main() {
r := gin.Default()
r.Use(gzip.Gzip(gzip.DefaultCompression))
r.GET("/ping", func(c *gin.Context) {
c.String( http.StatusOK, "pong "+fmt.Sprint(time.Now().Unix()))
})

// Listen and Server in 0.0.0.0:8080
r.Run(":8080")
}
```

官方提供 middleware

不错

有什么意义。。。

gin 不香吗, 哈哈

ctx, _ := context.WithTimeout(context.TODO(), time.Second*3)

你外部都忽略了返回的 cancel， 外部都没有 cancel()， 控制毛线

建议看下 context 相关知识

```go
func main() {
var (
sum = 100000
wg sync.WaitGroup
)
rs := make(chan bool, sum)
for i := 0; i < sum; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
ping(rs, i, "http://www.baidu.com")
}(i)
}

wg.Wait()
close(rs)

sl := make([]interface{}, 0, sum)
for v := range rs {
sl = append(sl, v)
}

fmt.Println(sl)
}

func ping(rs chan bool, i int, urlStr string) {
//reqquest url
fmt.Println(i, urlStr)

rs <- true
}
```

模拟你的需求写了个

dto vo po

一般是发送 goroutine 是 close 发送的 chan，接收 goroutine 是关闭阻塞 chan
这样的好处是不会造成 goroutine 泄露，发送完 close，接收 for chan 还是可以接收完数据的，会自己退出，这时候 close 或者发送信号到退出 chan 。

@ericgui 所以是动作操作是通过请求方法来判断, url 只是表示资源

和 jinzhu/copier 对比下?

结构体并不是为了串起函数，而是为了面向对象，面向接口设计。别搞混了主次

就冲文字表达能力这个，极度不推荐

go 调用 so 就行, 我这里的图像识别算法都是封装成 so 给我 go 用的

难怪了...

notify 用于唤醒睡眠等待状态的线程, 而且并不是马上执行的, 而是转换为可被调度状态, 等待 cpu 的调度. 调用 notify 的本线程该吃吃该喝喝

@MoYi123 正解, 1 2 楼答的不是这个问题

@janxin +1

@labulaka521 不过改造下就好了，把 core/cmd 下的三个文件重构成 2 个，把 master 和 work 解耦。最好再把 web 服务和调度器再拆分下，二者通过 rpc 通信。这样子，web api，调度器，worker 完全解耦了，任意水平扩展了

楼主这样的目录架构 docker 化的话，可执行文件打包略大，web，调度器，work 其中一个修改就需要重新打包，耦合了。