Go   发布时间:2022-04-09  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了[日常] Go语言圣经--并发的循环习题大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

练习 8.4: 修改reverb2服务器,在每一个连接中使用sync.WaitGroup来计数活跃的echo goroutIne。当计数减为零时,关闭TCP连接的写入,像练习8.3中一样。验证一下你的修改版netcat3客户端会一直等待所有的并发“喊叫”完成,即使是在标准输入流已经关闭的情况下。

重点:等待所有的goroutIne执行完成后再关闭TCP连接

Highlighter">

import (
"bufio"
"fmt"
"log"
"net"
"Strings"
"time"
"sync"
)

func main() {
listener,err := net.Listen("tcp",":8040")
if err != nil {
log.Fatal(err)
}

    for {
            conn,err := listener.Accept()
            if err != nil {
                    log.Print(err) // e.g.,connection aborted
                    conTinue
            }   
            go handleConn(conn) //新建goroutInes处理连接
    }   

}

func handleConn(c net.Conn) {
input := bufio.NewScAnner(C)
var wg sync.WaitGroup
//var ch =make(chan struct{})
for input.Scan() {
wg.Add(1)
go func(c net.Conn,shout String,delay time.Duration) {
defer wg.Done()
fmt.Fprintln(c,"\t",Strings.ToUpper(shout))
time.Sleep(delay)
fmt.Fprintln(c,shout)
time.Sleep(delay)
fmt.Fprintln(c,Strings.ToLower(shout))
//ch<-struct{}{}

            }(c,input.Text(),1*time.Second)
    }   
    wg.Wait()
            //cw := c.(*net.TCPConn)
      //cw.CloseWrite()

    c.Close()

}

  

大佬总结

以上是大佬教程为你收集整理的[日常] Go语言圣经--并发的循环习题全部内容,希望文章能够帮你解决[日常] Go语言圣经--并发的循环习题所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签: