golang 在 routine 中执行阻塞任务可以实现吗？

[Latin]

golang 新手请教下在协程中执行死循环任务并调度是否可以实现，没找到太多相关样例

https://github.com/hybridgroup/gocv/issues/191
找到了线程不安全的 issue

[ZSeptember]

什么意思，for{ // XXX} 不行吗。

[dongisking]

https://studygolang.com/articles/12992?fr=sidebar

[Latin]

@ZSeptember
解码服务要一直执行，
相当于一个协程一路解码，
肯定会阻塞协程，
刚刚试了几个实现都没成功

[ZSeptember]

可以多点上下文吧。再什么场景下，要做什么，达成什么样的效果。

[lbp0200]

sync.waitgroup

[chensan]

不太理解楼主是要什么效果，但是 context 和楼上的 waitgroup 你可以了解下

[Latin]

前者可以实现轮询调度
https://paste.ubuntu.com/p/thsKMhWC2x/
后者 gocv 不支持
https://paste.ubuntu.com/p/3F3wvYqGDM/
@ZSeptember @lbp0200 @chensan

[mengzhuo]

这样？


ch := make(chan, int)

go func() {

for i:=0;i<10;i++{
ch<-i
time.Sleep(i*500*time.Millisecond)
}

}()

for {
fmt.Print(<-ch)
}

[Latin]

@mengzhuo 好的 我试试

[lbp0200]

@Latin 看样子是 openCV 的问题，可以写成命令行

cap rtsp://xxx1
cap rtsp://xxx2
cap rtsp://xxx3

这样都是独立的进程，应该就没问题了

[ZSeptember]

defer wg.Done() 加到第七行前面，wg.Done 应该要在 goroutine 结束后执行吧。

[Latin]

@lbp0200 gocv 线程不安全 这个方法我觉得可以放弃了
@ZSeptember 阻塞可以直接放弃 Done 了吧

[ZSeptember]

打个日志看看你真实代码传入的 url 列表？感觉运行的时候是个空列表？

[lbp0200]

@Latin gocv 有示例代码，复制粘贴就好了

多视频源，就需要启动多个进程