jjzjj

go - 访问 URL 时终止 go routine

coder 2024-07-07 原文

我使用 Go 制作了一个简单的网络应用程序。有一个 goroutine 当用户访问一个 URL 时执行，比方说 /inspection/start/。如何在用户访问 URL /inspection/stop/ 时停止该 goroutine？

我听说过 channel，但我不确定在我的情况下该怎么做。

代码如下:

func inspection_form_handler(w http.ResponseWriter, r *http.Request) {
    if r.FormValue("save") != "" {
        airport_id := getCurrentAirportId(r)

        r.ParseForm()
        if airport_id != nil {
            if r.FormValue("action") == "add"{
                go read_serial_port()
            }

            // redirect back to the list
            http.Redirect(w, r, "/airport#inspect", http.StatusSeeOther)
        }
    }
}

常规函数

func read_serial_port(){
    c := &serial.Config{Name:"/dev/ttyACM0", Baud:9600}
    s, err := serial.OpenPort(c)

    if err != nil {
        log.Fatal(err)
    }

    filename:= randSeq(10)+".txt"
    file, _ := os.Create("output/"+filename)

    defer file.Close();

    for{
        buf := make([]byte, 128)
        n, err := s.Read(buf)

        if err != nil {
            log.Fatal(err)
        }

        log.Printf("%s", string(buf[:n]))

        fmt.Fprintf(file, string(buf[:n]))

        time.Sleep(100 * time.Millisecond)
    }
}

最佳答案

你可以通过使用时间标记和上下文来实现

func read_serial_port(c context.Context){
    c := &serial.Config{Name:"/dev/ttyACM0", Baud:9600}
    s, err := serial.OpenPort(c)

    if err != nil {
        log.Fatal(err)
    }

    filename:= randSeq(10)+".txt"
    file, _ := os.Create("output/"+filename)

    defer file.Close();

    ticker := time.NewTicker(100 * time.Millisecond)
    defer ticker.Stop()

    for{
        select {
        case <-c.Done():
            break
        case <-ticker.C:
            buf := make([]byte, 128)
            n, err := s.Read(buf)

            if err != nil {
                log.Fatal(err)
            }

            log.Printf("%s", string(buf[:n]))

            fmt.Fprintf(file, string(buf[:n]))

            time.Sleep(100 * time.Millisecond)
        }
    }
}

然后你需要添加另一个路由来调用取消函数

if r.FormValue("action") == "add"{
    c, cnl := context.WithCancel(context.Background())
    // need to access this cancel function to use it in another route
    ExportedFunction = cnl
    go read_serial_port()
}

然后通过以下方式取消它:

func abortingMission(w http.ResponseWriter, r *http.Request) {
    ExportedFunction()
}

并且不要在你的函数名中使用下划线

关于go - 访问 URL 时终止 go routine，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/52585675/

routinegocode34section

有关go - 访问 URL 时终止 go routine的更多相关文章

  1. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法？ - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  2. ruby-on-rails - 在混合/模块中覆盖模型的属性访问器 - 2

    我有一个包含模块的模型。我想在模块中覆盖模型的访问器方法。例如:classBlah这显然行不通。有什么想法可以实现吗？ 最佳答案 您的代码看起来是正确的。我们正在毫无困难地使用这个确切的模式。如果我没记错的话，Rails使用#method_missing作为属性setter，因此您的模块将优先，阻止ActiveRecord的setter。如果您正在使用ActiveSupport::Concern(参见thisblogpost)，那么您的实例方法需要进入一个特殊的模块:classBlah

  3. ruby-on-rails - rails : save file from URL and save it to Amazon S3 - 2

    从给定URL下载文件并立即将其上传到AmazonS3的更直接的方法是什么(+将有关文件的一些信息保存到数据库中，例如名称、大小等)？现在，我既不使用Paperclip，也不使用Carrierwave。谢谢 最佳答案 简单明了:require'open-uri'require's3'amazon=S3::Service.new(access_key_id:'KEY',secret_access_key:'KEY')bucket=amazon.buckets.find('image_storage')url='http://www.ex

  4. ruby - 续集在添加关联时访问many_to_many连接表 - 2

    我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作)，这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以

  5. ruby - 如何使用 Ruby aws/s3 Gem 生成安全 URL 以从 s3 下载文件 - 2

    我正在编写一个小脚本来定位aws存储桶中的特定文件，并创建一个临时验证的url以发送给同事。(理想情况下，这将创建类似于在控制台上右键单击存储桶中的文件并复制链接地址的结果)。我研究过回形针，它似乎不符合这个标准，但我可能只是不知道它的全部功能。我尝试了以下方法:defauthenticated_url(file_name,bucket)AWS::S3::S3Object.url_for(file_name,bucket,:secure=>true,:expires=>20*60)end产生这种类型的结果:...-1.amazonaws.com/file_path/file.zip.A

  6. ruby-on-rails - Ruby url 到 html 链接转换 - 2

    我正在使用Rails构建一个简单的聊天应用程序。当用户输入url时，我希望将其输出为html链接(即“url”)。我想知道在Ruby中是否有任何库或众所周知的方法可以做到这一点。如果没有，我有一些不错的正则表达式示例代码可以使用... 最佳答案 查看auto_linkRails提供的辅助方法。这会将所有URL和电子邮件地址变成可点击的链接(htmlanchor标记)。这是文档中的代码示例。auto_link("Gotohttp://www.rubyonrails.organdsayhellotodavid@loudthinking.

  7. ruby-on-rails - 如何生成传递一些自定义参数的 `link_to` URL？ - 2

    我正在使用RubyonRails3.0.9，我想生成一个传递一些自定义参数的link_toURL。也就是说，有一个articles_path(www.my_web_site_name.com/articles)我想生成如下内容:link_to'Samplelinktitle',...#HereIshouldimplementthecode#=>'http://www.my_web_site_name.com/articles?param1=value1¶m2=value2&...我如何编写link_to语句“alàRubyonRailsWay”以实现该目的？如果我想通过传递一些

  8. ruby - Rack:如何将 URL 存储为变量？ - 2

    我正在编写一个简单的静态Rack应用程序。查看下面的config.ru代码:useRack::Static,:urls=>["/elements","/img","/pages","/users","/css","/js"],:root=>"archive"map'/'dorunProc.new{|env|[200,{'Content-Type'=>'text/html','Cache-Control'=>'public,max-age=6400'},File.open('archive/splash.html',File::RDONLY)]}endmap'/pages/search.

  9. ruby-on-rails - Rails - 使用/自定义 URL : '/dashboard' 指定根路径 - 2

    如何使此根路径转到:“/dashboard”而不仅仅是http://example.com？root:to=>'dashboard#index',:constraints=>lambda{|req|!req.session[:user_id].blank?} 最佳答案 您可以通过以下方式实现:root:to=>redirect('/dashboard')match'/dashboard',:to=>"dashboard#index",:constraints=>lambda{|req|!req.session[:user_id].b

  10. ruby - 有没有办法从 ruby​​ case 语句中访问表达式？ - 2

    我想从then子句中访问c​​ase语句表达式，即food="cheese"casefoodwhen"dip"then"carrotsticks"when"cheese"then"#{expr}crackers"else"mayo"end在这种情况下，expr是食物的当前值(value)。在这种情况下，我知道，我可以简单地访问变量food，但是在某些情况下，该值可能无法再访问(array.shift等)。除了将expr移出到局部变量然后访问它之外，是否有直接访问caseexpr值的方法？罗亚附注我知道这个具体示例很简单，只是一个示例场景。 最佳答案

随机推荐