- xml - AJAX/Jquery XML 解析
- 具有多重继承的 XML 模式
- .net - 枚举序列化 Json 与 XML
- XML 简单类型、简单内容、复杂类型、复杂内容
我有以下实现工作队列的代码:
package main
import (
"fmt"
"net/http"
"io"
"time"
)
var (
linkQueue chan Link
scraperQueue chan chan Link
)
func CycleDirectory(page int) {
linkQueue <- Link{Name: "asd"}
}
type Link struct {
Name string
}
func (s Scraper) Start() {
fmt.Println("Started")
go func() {
for {
s.ScraperQueue <- s.Link
select {
case link := <-s.Link:
fmt.Println(fmt.Sprintf("%v", s.Id) + ": Received " + link.Name)
case <-s.QuitChan:
fmt.Println("Closed")
return
}
}
}()
}
func (s Scraper) Stop() {
go func() {
s.QuitChan <- true
}()
}
type Scraper struct {
Id int
Link chan Link
ScraperQueue chan chan Link
QuitChan chan bool
}
func InitScraper(id int, scraperQueue chan chan Link) Scraper {
return Scraper {
Id: id,
Link: make(chan Link),
ScraperQueue: scraperQueue,
QuitChan: make(chan bool),
}
}
func HelloServer(w http.ResponseWriter, req *http.Request) {
io.WriteString(w, "hello, world!\n")
}
func main() {
linkQueue = make(chan Link, 2000)
numScrapers := 2
scraperQueue = make(chan chan Link, numScrapers)
for i := 0; i < numScrapers; i++ {
s := InitScraper(i+1, scraperQueue)
s.Start()
}
go func() {
for {
select {
case link := <-linkQueue:
go func() {
scraper := <-scraperQueue
scraper <- link
}()
}
}
}()
CycleDirectory(1)
// time.Sleep(1 * time.Millisecond)
for {
// select {
// }
}
// http.HandleFunc("/hello", HelloServer)
// http.ListenAndServe(":12345", nil)
}
使用包含 if 语句(或内部没有任何内容)的 for 循环运行此代码,爬虫不会打印收到的消息。使用来自 net/http 的 ListenAndServe 函数进行阻塞,它打印接收到的消息。使用 sleep 阻塞 1 毫秒,我收到消息。在 for 循环中放置一个 select 语句,我也收到了消息。
为什么没有 select 语句的 for 循环不允许执行在工作队列中发送的消息,我将如何处理这个问题。我需要 for 循环中的 if 语句来检查是否所有工作都已完成,以便我可以退出循环并结束程序。
更新
Amd 的建议是解决这个问题的方法。这是我使用 sync.WaitGroup 更新的代码 包主
import (
"fmt"
"sync"
)
var (
linkQueue chan Link
scraperQueue chan chan Link
wg sync.WaitGroup
)
func CycleDirectory(page int) {
wg.Add(1)
linkQueue <- Link{Name: "asd"}
}
type Link struct {
Name string
}
func (s Scraper) Start() {
fmt.Println("Started")
go func() {
for {
s.ScraperQueue <- s.Link
select {
case link := <-s.Link:
Scrape(s.Id, link.Name)
s.Stop()
case <-s.QuitChan:
fmt.Println("Closed")
wg.Done()
return
}
}
}()
}
func (s Scraper) Stop() {
go func() {
s.QuitChan <- true
}()
}
type Scraper struct {
Id int
Link chan Link
ScraperQueue chan chan Link
QuitChan chan bool
}
func Scrape(id int, name string) {
fmt.Println(fmt.Sprintf("%v", id) + ": Received " + name)
}
func InitScraper(id int, scraperQueue chan chan Link) Scraper {
return Scraper {
Id: id,
Link: make(chan Link),
ScraperQueue: scraperQueue,
QuitChan: make(chan bool),
}
}
func main() {
linkQueue = make(chan Link, 2000)
numScrapers := 2
scraperQueue = make(chan chan Link, numScrapers)
for i := 0; i < numScrapers; i++ {
s := InitScraper(i+1, scraperQueue)
s.Start()
}
go func() {
for {
select {
case link := <-linkQueue:
go func() {
scraper := <-scraperQueue
scraper <- link
}()
}
}
}()
CycleDirectory(1)
wg.Wait()
fmt.Println("Done")
}
最佳答案
您可以使用sync.WaitGroup
来阻止程序退出,直到所有工作完成。
试试 The Go Playground :
package main
import (
"fmt"
"sync"
"time"
)
var (
wg sync.WaitGroup
)
func main() {
wg.Add(1)
go func() {
defer wg.Done()
time.Sleep(2 * time.Second)
}()
fmt.Println("Wait...")
wg.Wait()
fmt.Println("Done.")
}
关于Goroutines被for循环阻塞?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39642189/
发件人:http://blog.nindalf.com/how-goroutines-work/ As the goroutines are scheduled cooperatively, a go
很多时候在用 Go 开发 http 服务器时,我都会遇到这种困境。 假设我想尽快用http statuscode 200响应客户端(然后在后面执行工作),这就是我通常这样做的原因: 我让我的主要 ht
这是代码: import "fmt" func main() { messages := make(chan string, 1) go func(c chan string) {
我正在学习 Golang,但遇到了一些困难。我已经研究过 Google,但没有任何进展。 我编写了一个代码,通过多台服务器的 ICMP 检查 RTT。 它有这样的结构: type Server str
我想运行多个 goroutine,进行一些处理,将结果放入 channel ,当至少有一个 goroutine 完成时,完成所有其他 goroutine 并从 channel 返回结果。 所以,我尝试
我有两个(但以后我会是三个)go 例程来处理来自远程服务器(来自 ampq channel )的传入消息。但是因为它们正在处理相同的数据/状态,所以我想阻止所有其他 go 例程,除了正在运行的例程。
我有一个案例,我从 2 个不同的位置(ES 和 REDIS)读取数据,我需要从最快的源读取一个值,因此我触发了 2 个 goroutines,一个从 ES 获取数据,其他从REDIS获取。 一旦从其中
像这里一样,我创建了一个 go playground 示例:sGgxEh40ev ,但无法正常工作。 quit := make(chan bool) res := make(chan int) go
我是golang的新手,正在研究goroutine。 我写了一个简单的代码,故意使用 goroutine 来划分数字。 首先,我给出基数并继续除它的数,直到它不能被整除 但是,我改变了go split
Main { go routine_1(carryout a time consuming task and return output) go routine_2(wait for output f
我想知道从另一个 goroutine 返回时调用的 goroutine 会发生什么。他们是继续运行还是被终止?这是一个示例代码来说明我的意思: func func() { // Doing s
更具体地说,在我的例子中,我有一个网络服务器和一个全局可访问的结构,网络服务器使用它来生成页面。我有另一个 Goroutine,它总是定期用新值更新该结构。这会引起问题吗?我是否需要实现一种机制来确保
来自 this file ,我不明白为什么函数startWorker会这样写: func (p *WorkerPool) dispatch() { for i := 0; i < p.maxW
我正在学习围棋,但在使用 goroutines 时遇到了问题。这是我的代码 package main import ( "fmt" "sync" "time" ) var co
我收到以下错误,我不明白为什么: 发送:查询 Herefatal 错误:所有 goroutines 都睡着了 - 死锁! 您可以看到我正在调用我使用 goroutine 创建的函数 routine。我
大家好,我正在从 Python3 过渡到 Go,所以我正在尝试重写我创建的库以获得更好的性能。 我面临一个问题,因为我是 Golang XD 中的新手,我使用有限的 API 下载数百个 json,我想
我有以下格式的脚本部分: func main() { for i=0;i<1000000;i++ { go test() } } func test() { a := test
package main func main() { c:=make(chan int) for i:=0; i<=100;i++ {
我正在学习 Go,我的第一个项目是一个简单的 ping 脚本。本质上,我想 ping 一堆 url,并在每个响应时等待 XXX 秒,然后再次 ping。这是删减的代码: func mai
这个问题在这里已经有了答案: Go all goroutines are asleep deadlock (2 个回答) fatal error: all goroutines are asleep
我是一名优秀的程序员,十分优秀!