正如我从golang文档中了解到的,如果我使用8个内核的cpu(intel
i7)设置runtime.GOMAXPROCS(8),然后启动无限循环goroutine,则不应阻塞其他gorutine,因为有足够的线程和goprocs。但是,当使用net
/ http包时,情况并非如此,无限循环goroutine会在几次调用后阻塞http服务器。谁能帮助解释原因?
服务器代码:
package main
import (
"fmt"
"log"
"net/http"
"runtime"
)
func myHandler(w http.ResponseWriter, req *http.Request) {
w.Write([]byte("hello"))
}
func infiniteloop() {
for {
}
}
func main() {
// set max procs for multi-thread executing
runtime.GOMAXPROCS(runtime.NumCPU())
// print GOMAXPROCS=8 on my computer
fmt.Println("GOMAXPROCS=", runtime.GOMAXPROCS(-1))
http.Handle("/", http.HandlerFunc(myHandler))
// uncomment below line cause server block after some requests
// go infiniteloop()
if err := http.ListenAndServe(":8280", nil); err != nil {
log.Fatal(err)
}
}
客户代码:
package main
import (
"fmt"
"net/http"
)
func getOnce() {
if resp, err := http.Get("http://localhost:8280"); err != nil {
fmt.Println(err)
return
} else {
defer func() {
if err := resp.Body.Close(); err != nil {
fmt.Println(err)
}
}()
if resp.StatusCode != 200 {
fmt.Println("error codde:", resp.StatusCode)
return
} else {
fmt.Print("*")
}
}
}
func main() {
for i := 1; i < 1000; i++ {
getOnce()
if i%50 == 0 {
fmt.Println()
}
}
}
现在我知道为什么这样的空循环会阻塞其他goroutine,但是为什么runtime.LockOSThread()
也没有帮助?
func infiniteloop() {
// add LockOSThread will not help
runtime.LockOSThread()
for {
}
}
如http://golang.org/pkg/runtime/#LockOSThread所述,空循环应在独立线程中执行,而其他goroutine不应受到繁忙循环的影响。我的理解有什么问题?
我有一个带感应帽的覆盆子皮。我制作了一个二进制时钟,我想在Sense hat的显示器上显示并保持更新。然而,我想要的能力,开关时钟与操纵杆中间。一切都很好,除了我的时钟的更新循环阻止任何新的输入一旦启动。 我一直在考虑如何解决这个问题。如何允许脚本/时钟保持运行,并且仍然接受来自操纵杆的新操作。但是一旦while循环开始,我就卡住了。我不知道该用谷歌搜索什么。我已经开始研究async/await,
问题内容: 我有以下代码实现了工作队列: 使用包含if语句(或内部没有任何内容)的for循环运行此代码,爬虫不会打印收到的消息。使用net / http中的ListenAndServe函数进行阻止,它将打印收到的消息。使用睡眠阻止1毫秒,我收到了消息。并将select语句放入for循环中,我也收到消息。 为什么没有select语句的for循环不允许执行在工作队列中发送的消息,以及我将如何处理这一问
我想构建一个无头应用程序,它将在无限循环中查询数据库,并在某些条件下执行一些操作(例如,获取具有特定值的记录,当发现时,为每个消息启动电子邮件发送过程)。 我想使用Spring Boot作为基础(特别是因为Actuator允许公开健康检查),但现在我使用Spring Boot构建REST Web服务。 在构建无限循环应用程序时,是否有任何最佳实践或模式可遵循?有没有人试图基于Spring Boot
无法启动nginx服务器OS:ubuntu服务器16.04 systemctl status nginx.status抛出此消息:nginx.service-高性能web服务器和反向代理服务器加载:加载(/lib/systemd/system/nginx.service;enabled;vendor preset:enabled)活动:失败(结果:exit-code)自UTC Thu 2016-1
问题内容: 此代码将导致无限循环的机会是什么? 实际上,这会导致无限循环。我的怀疑是因为我没有服用,是真的吗? 问题答案: 是。除非您不打电话,否则它将永远不会继续进行下一项。Beause 将返回您已在列表/集中添加的对象。
问题内容: 我不知道发生了什么问题…我无法在服务中启动计时器。遵循代码 但是当我到达生产线时,我得到了以下异常 03-03-23:32:14.851:E / AndroidRuntime(6083):java.lang.RuntimeException:无法使用意图{cmp = mt.android.app / .BkgService}启动服务mt.android.app.BkgService@4