登录
首页 >  Golang >  Go问答

如何改造下面的方法,让正常结束

来源:SegmentFault

时间:2023-02-17 10:30:22 119浏览 收藏

本篇文章向大家介绍《如何改造下面的方法,让正常结束》,主要包括go,具有一定的参考价值,需要的朋友可以参考一下。

问题内容

下面的方法现在会进入假死状态,问题:
1.错误原因按理解标注上了,不知道对不对?不对请帮忙重新解释下。
2.现在想请教大佬如何改造,只要能正常都有哪些改造方法。
但是不能用带缓存的chan,这个已经测试可以。
3.现在写法错误,主要问题是没有关闭chan,这样理解对吗?

package main

import (
    "fmt"
    "sync"
    "testing"
)

/**
配合wait 关闭chan后读取chan
不带缓存,必须是有空间才能写入
错误示例eg: 不带缓存chan 并发写入 select读取
错误原因:程序进入假死状态 ,因为close(info)要等w.Wait(),而w.Wait()要等for more{},这个循环体里不关闭,就进入假死状态
*/
func test1_error(t *testing.T) {
    info := make(chan string)
    datas := []string{"a", "b", "c"}
    var w sync.WaitGroup
    w.Add(len(datas))
    for _, v := range datas {
        go func(info_ chan string, v_ string, w *sync.WaitGroup) {
            defer w.Done()
            fmt.Println("data:" + v_)
            //核心业务逻辑
            v_ = v_ + v_ //这里一定要用参数v_
            //管道写入
            info_ 

正确答案

因为

for more
会堵塞主线程,执行不到下面的
close
.另开一个goroutine就可以了

func test1_error(t *testing.T) {
    info := make(chan string)
    datas := []string{"a", "b", "c"}
    var wg sync.WaitGroup
    wg.Add(len(datas))
    go func(){
        wg.Wait()
        //配合wait 此时可以关闭chan.如果是某一个协程写,就在那个协程里关闭chan
        close(info)
    }()
    for _, v := range datas {
        go func(info_ chan string, v_ string, w *sync.WaitGroup) {
            defer wg.Done()
            fmt.Println("data:" + v_)
            //核心业务逻辑
            v_ = v_ + v_ //这里一定要用参数v_
            //管道写入
            info_ 

文中关于golang的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《如何改造下面的方法,让正常结束》文章吧,也可关注golang学习网公众号了解相关技术文章。

声明:本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表