回复中， 写代码怎么 md 不生效了= =

@linjunyi22 感谢， 刚学习 go，有一些概念改搞不清。但是你这种方法好像会造成接收不完全就会退出。我自己也解决了这个问题了。

```
package main

import (
"context"
"fmt"
"math/rand"
"sync"
"time"
)

var (
wg = sync.WaitGroup{} // 用于计数， 让程序正常执行，不会主函数执行完子函数还没执行。计数清 0 则不用等待
a int
//lock sync.Mutex
rwlock sync.RWMutex
icons map[string]string
loadIconsOnce sync.Once
//m sync.Map
)

func randNumber(x int64) int64 {
var sum int64 = 0
for x > 0 {
a := x % 10
x = x / 10
sum += a
}
return sum
}


func main() {
wg.Add(25)
defer wg.Wait()
var maxSend = 10
var jobChan = make(chan int64, 10)
var resultChan = make(chan int64, 10)
var lock sync.Mutex
ctx, cancel := context.WithCancel(context.Background())

//var once sync.Once
go func(jobChan chan<- int64, ) {
for i:=0;i<maxSend;i++{
rand.Seed(time.Now().UnixNano())
jobChan <- rand.Int63n(100)
}
close(jobChan)
wg.Done()
}(jobChan)

count1 := 1
for i:=0;i<24;i++{
go func(jobChan <-chan int64, resultChan chan int64, ctx context.Context) {
defer wg.Done()
for num:= range jobChan{
select {
case <- ctx.Done():
return
case resultChan <- randNumber(num):
lock.Lock()
fmt.Println("count:", count1)
count1 += 1
lock.Unlock()
}

}
}(jobChan, resultChan, ctx)
}

num := maxSend
count := 1
for value := range resultChan {
if num == 1 {
fmt.Printf("key:%v, value:%v\n", count, value)
cancel()
return
}else {
num -= 1
fmt.Printf("key:%v, value:%v\n", count, value)
count += 1
}
}
}

```

@Jat001 如果没有 GPU，VPF 还可以使用么？

@Jat001 这个我只是用来看看的而已。

@oahebky 我看着看着文档， 怎么感觉 asyncio 使用起来场景限制很大，一般除了用在网络 IO， 还能用在什么地方呢？
如果用网络 IO， 和多线程其实也没什么区别啊， 反正也是卡在网络上。

@superrichman 使用协程收益确实不大， 但是我想了解下协程正确写法应该是怎么样的。。。

@9yu 谢谢。

@9yu 使用什么方式投诉？我现在都被快递整恶心了

就是需要 mysql 分布式、redis 分布式之类的。其实这些都搭建过，但是项目场景不适合，我也不知道该不该写上去。

@weishimi 你这个问题解决了么，我刚学了两天 docker， 也遇到这种问题了，感觉 docker 的作者不会没想到这点。。。

题主您好。
我也是遇到这样的问题，需要从海康摄像头抓取之后进行人脸识别，对视频进行处理之后进行 rtmp 进行推流。
我的代码:
size = (int(cap.get(cv2.CAP_PROP_FRAME_WIDTH)), int(cap.get(cv2.CAP_PROP_FRAME_HEIGHT)))
sizeStr = str(size[0]) + 'x' + str(size[1])
fps = cap.get(cv2.CAP_PROP_FPS) # 30p/self
fps = int(fps)
rtmpUrl = 'rtmp://192.168.1.71:1935/live/app'
command = ['ffmpeg',
'-y',
'-f', 'rawvideo',
'-vcodec','rawvideo',
'-pix_fmt', 'bgr24',
'-s', sizeStr,
'-r', str(fps),
'-i', '-',
'-c:v', 'libx264',
'-pix_fmt', 'yuv420p',
'-preset', 'ultrafast',
'-f', 'flv',
rtmpUrl]

while True:
ret, frame = cap.read()
proc = sp.Popen(command, stdin=sp.PIPE, shell=False)
proc.stdin.write(frame.tostring())
if cv2.waitKey(1) & 0xFF == ord('q'):
break

运行是成功了（也不能说成功，有时候会崩溃），但是用 VLC 却是不能拉流观看。
然后再想是否是你说的这个问题，从 numpy.ndarray->cv2.cv.cvmat。
但是在网上查资料说 mat_array = cv2.cv.fromarray(frame)，这个 opencv-python 2.4 之后就没了。
希望题主看到之后能解答一下！

@zuoxiaomo 海康没有 python 对应的 demo

@ziding 我就是看了这个文档。 他的 wsdl 文件如何来的。别笑话我，我是个菜鸟程序员- -

@yufpga 我知道有这种方式，但是我不懂 C++， 这样的话要麻烦同事。所以先看自己能否解决。

@xiaoheijw 老哥，能加微信私聊么？

@realpg 我们有海康的摄像头。但是不能直接调用，需要通过 CS 端转发。如果是能直接调用的话，通过控件延迟很低。
还涉及不同的摄像头，没办法统一，所以才想着搭一个服务器转发。

@xshwy 我们是在专网里面，不能上网。

@fgodt 谢谢老哥的建议，我们这里涉及不同的厂商，我们公司 CS 端的话（使用海康 SDK 方式取流），再传给我们，其他厂商都应该大同小异。但是因为我们不能直接调海康的接口。所以想采用的是搭一个服务器，他们把视频流传给服务器，再从服务器取视频（我也不太清楚这个方案靠不靠谱）。

@likuku 我需要延迟控制两秒以内。所以接受不了。