drd2551 2017-06-02 12:54
浏览 17

goroutine的变量没有时间注册

This piece of code gets an array with strings and should mix it and make a response (both multithreaded). The problem is that the text of the answer is randomly cutted. This is probably due to the fact that the variable "dump" does not have time to sign up completely. If it is wrapped in mutexes, the text is returned full, but threads are blocked and the program is executed for a long time. Please help!

const url = "https://yandex.ru/referats/write/?t=astronomy+mathematics"
const parseThreadsNum = 10
const generateThreadsNum = 1000

func startServer(wg *sync.WaitGroup) {
fmt.Println("Server started")
ch := make(chan []byte, generateThreadsNum)

http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
    wg.Add(generateThreadsNum)
    rawText := multiparseText() // text parsing
    prettyText := prettifyText(rawText) // truncates commas, dots etc. Return []string
    for i := 0; i < generateThreadsNum; i++ {
        go func() {
            dump, _ := json.Marshal(shuffle(&prettyText)) //shuffle mixes array randomly
            ch <- dump
        }()
        go func() {
            w.Write(<-ch)
            defer wg.Done()
        }()
    }
    fmt.Println("Text generated")
    wg.Wait()
})
log.Fatal(http.ListenAndServe(":8081", nil))
}

func main() {
var wg sync.WaitGroup
runtime.GOMAXPROCS(runtime.NumCPU())
startServer(&wg)

}
  • 写回答

0条回答 默认 最新

    报告相同问题?

    悬赏问题

    • ¥15 基于卷积神经网络的声纹识别
    • ¥15 Python中的request,如何使用ssr节点,通过代理requests网页。本人在泰国,需要用大陆ip才能玩网页游戏,合法合规。
    • ¥100 为什么这个恒流源电路不能恒流?
    • ¥15 有偿求跨组件数据流路径图
    • ¥15 写一个方法checkPerson,入参实体类Person,出参布尔值
    • ¥15 我想咨询一下路面纹理三维点云数据处理的一些问题,上传的坐标文件里是怎么对无序点进行编号的,以及xy坐标在处理的时候是进行整体模型分片处理的吗
    • ¥15 CSAPPattacklab
    • ¥15 一直显示正在等待HID—ISP
    • ¥15 Python turtle 画图
    • ¥15 stm32开发clion时遇到的编译问题