登录
首页 >  Golang >  Go问答

如何使用signal,break一个有阻塞监听的for循环?

来源:SegmentFault

时间:2023-01-24 18:22:19 223浏览 收藏

来到golang学习网的大家,相信都是编程学习爱好者,希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《如何使用signal,break一个有阻塞监听的for循环?》,介绍一下go,希望对大家的知识积累有所帮助,助力实战开发!

问题内容

func Soo(){
    tcpAddr, _ := net.ResolveTCPAddr("tcp", ipaddr)
    tcpListener, _ := net.ListenTCP("tcp", tcpAddr)
    for {
        tcpConn, err := tcpListener.AcceptTCP()
        if err != nil {
            fmt.Println("accept error: ", err)
        }
        defer tcpConn.Close()

        go Dotings(tcpConn)
    }
}

因为代码会在 tcpListener.AcceptTCP()处阻塞监听,想使用signal实现键盘Ctrl+C,break出for循环。该如何实现?

正确答案

简单一点的办法就是新开一个线程去Accept, 收到Signal之后Close掉Listener, 然后这个时候Accept会立即返回一个Error

use of closed network connection
. 代码大概长这样:

func server(stopSignal chan int) {
    l, _ := net.Listen("tcp", ":8888")
    cr := make(chan net.Conn)
    go func(l net.Listener, cr chan net.Conn) {
        for {
            conn, err := l.Accept()
            if err != nil {
                log.Printf("accept error: %s", err)
                l.Close()
                break
            }
            cr 

调用的时候传入一个参数

stopSignal
, 当收到这个
signal
的时候会立即停止Accept. 测试可以这样写:

func main() {
    sig := make(chan int)
    go server(sig)
    time.Sleep(time.Second * 4)
    sig 

如果要换种方式, 估计就得用syscall拿到原始的fd再调用

syscall.SetNonblock
设置成非阻塞模式了.

到这里,我们也就讲完了《如何使用signal,break一个有阻塞监听的for循环?》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于golang的知识点!

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