go - 拉 0 大小的 golang chan

coder 2024-07-05 原文

我的用例如下:我需要向 0...N 订阅者发送 POST 请求，这些订阅者由 targetUrl 表示。我想将 goroutine 的最大数量限制为 100。我的代码(简化)如下:

package main

import (
    "fmt"
    "log"
    "net/http"
    "errors"
)

const MAX_CONCURRENT_NOTIFICATIONS = 100

type Subscription struct {
    TargetUrl string
}

func notifySubscribers(subs []Subscription) {
    log.Println("notifySubscribers")
    var buffer = make(chan Subscription, len(subs))
    defer close(buffer)

    for i := 0; i < MAX_CONCURRENT_NOTIFICATIONS; i++ {
            go notifySubscriber(buffer)
    }

    for i := range subs {
            buffer <- subs[i]
    }
}

func notifySubscriber(buffer chan Subscription) {
    log.Println("notifySubscriber")
    for {
            select {
            case sub := <-buffer:
                    log.Println("sending notification to " + sub.TargetUrl)

                    resp, err := failPost()
                    if err != nil {
                            log.Println(fmt.Sprintf("failed to notify %s. error: %s", sub.TargetUrl, err.Error()))
                    } else {
                            resp.Body.Close()

                            if resp.StatusCode != http.StatusOK {
                                    log.Println(fmt.Sprintf("%s responded with %d", sub.TargetUrl, resp.StatusCode))
                            }
                    }
            }
            log.Println(fmt.Sprintf("buffer size: %d", len(buffer)))
    }
}

func failPost() (*http.Response, error) {
    return &http.Response{
            StatusCode: http.StatusBadRequest,
    }, errors.New("some bad error")
}

func main() {
    log.Println("main")
    var subs []Subscription
    subs = append(subs, Subscription{TargetUrl: "http://foo.bar"})
    subs = append(subs, Subscription{TargetUrl: "http://fizz.buzz"})

    notifySubscribers(subs)
    select {}
}

输出如下: 2018/01/24 10:52:48 通知失败。错误:一些严重的错误 2018/01/24 10:52:48 缓冲区大小:1 2018/01/24 10:52:48 发送通知给 2018/01/24 10:52:48 通知失败。错误:一些严重的错误 2018/01/24 10:52:48 缓冲区大小:0 2018/01/24 10:52:48 发送通知给 2018/01/24 10:52:48 通知失败。错误:一些严重的错误 ...等等，直到我 SIGINT 程序

所以基本上这意味着我已经成功地将通知发送给了正确的人，但我仍然继续发送到空的 targetUrl，因为我从一个空的 chan 中读取。

怎么了？

[编辑] 解决方法，但我不喜欢它

for {
    select {
        case sub, more := <-buffer:
            if !more {
                return
            }
    }
}

最佳答案

这是因为您正在关闭缓冲区，但您的 notifySubscriber 仍在监听缓冲区。关闭的 channel 始终返回默认类型值(在本例中为空 Subscription 和空 TargetURL)。因此，您得到一个空字符串。

场景:

如果你想保持 goroutines 运行，那么不要关闭缓冲区。
工作完成后停止 goroutine，然后关闭缓冲区。

关于go - 拉 0 大小的 golang chan，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/48419499/

有关go - 拉 0 大小的 golang chan的更多相关文章

ruby-on-rails - 在 Rails 中将文件大小字符串转换为等效千字节 - 2
我的目标是转换表单输入，例如“100兆字节”或“1GB”，并将其转换为我可以存储在数据库中的文件大小(以千字节为单位)。目前，我有这个:defquota_convert@regex=/([0-9]+)(.*)s/@sizes=%w{kilobytemegabytegigabyte}m=self.quota.match(@regex)if@sizes.include?m[2]eval("self.quota=#{m[1]}.#{m[2]}")endend这有效，但前提是输入是倍数(“gigabytes”，而不是“gigabyte”)并且由于使用了eval看起来疯狂不安全。所以，功能正常，
HBase Region 简介和建议数量&大小 - 2
Region是HBase数据管理的基本单位,region有一点像关系型数据的分区。region中存储这用户的真实数据，而为了管理这些数据，HBase使用了RegionSever来管理region。Region的结构hbaseregion的大小设置默认情况下，每个Table起初只有一个Region，随着数据的不断写入，Region会自动进行拆分。刚拆分时，两个子Region都位于当前的RegionServer，但处于负载均衡的考虑，HMaster有可能会将某个Region转移给其他的RegionServer。RegionSplit时机：当1个region中的某个Store下所有StoreFile
ruby-on-rails - Ruby 中意外的大小写行为 - 2
我在一段非常简单的代码(如我所想)中得到了一个错误的值:org=4caseorgwhenorg=4val='H'endputsval=>nil请不要生气，我希望我错过了一些非常明显的东西，但我真的想不通。谢谢。最佳答案这是典型的Ruby错误。case有两种被调用的方法，一种是你传递一个东西作为分支的基础，另一种是你不传递的东西。如果您确实在case中指定了一个表达式语句然后评估所有其他条件并与===进行比较.在这种情况下org评估为false和org===false显然不是真的。所有其他情况也是如此，它们要么是真的，要么是假的。
ruby - 改变替换的大小写 - 2
我有以下内容:text.gsub(/(lower)(upper)/,'\1\2')我可以将\2替换为大写吗？类似于:sed-e's/$abc$/\U\1/'这在Ruby中可行吗？最佳答案查看gsub文档:str.gsub(模式){|匹配|block}→new_str在block形式中，当前匹配字符串作为参数传入，$1、$2、$`、$&、$'等变量将被适当设置。block返回的值将替换为每次调用的匹配项。"alowerupperb".gsub(/(lower)(upper)/){|s|$1+""+$2.upcase}
ruby - Sinatra:哈希的未定义方法字节大小 - 2
很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈，无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开，visitthehelpcenter.关闭9年前。我正在创建一个Sinatra应用程序，它采用上传的CSV文件并将其内容放入哈希中。当我像这样在我的app.rb中引用这个散列时:hash=extract_values(path_to_filename)我不断收到此错误消息:undefinedmethod`bytesize'forHash:0x007fc5e28f2b90#object_idfile:utils.rblocation:bytesiz
ruby - 使2个数组大小相同 - 2
2个数组的数组:a=[[1,2],[22,11],[18,9]]b=[[1,81]]用[0,0]填充第二个的最佳方法是什么，以便它们具有相同的大小？最佳答案 b.fill(b.size..a.size-1){[0,0]} 关于ruby-使2个数组大小相同，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/29725615/
ruby - 数组大小太大 - ruby - 2
我收到“ArgumentError:数组大小太大”消息，代码如下:MAX_NUMBER=600_000_000my_array=Array.new(MAX_NUMBER)问题。Array.new函数在Ruby中的最大值是多少？最佳答案具有5亿个元素的数组的大小为2GiBytes，这取决于您使用的特定操作系统，通常是一个进程可以处理的最大值。换句话说:您的数组大于您的地址空间。因此，解决方案很明显:要么缩小数组(例如，将其分成block)，要么扩大地址空间(在Linux中，您可以修补内核以获得3、3.5甚至4GiByte地址空间，
ruby-on-rails - Textmate 'Go to symbol' 相当于 Vim - 2
在Railcasts上，我注意到一个非常有趣的功能“转到符号”窗口。它像Command-T一样工作，但显示当前文件中可用的类和方法。如何在vim中获取它？最佳答案尝试:helptags有各种程序和脚本可以生成标记文件。此外，标记文件格式非常简单，因此很容易将sed(1)或类似的脚本组合在一起，无论您使用何种语言，它们都可以生成标记文件。轻松获取标记文件(除了下载生成器之外)的关键在于格式化样式而不是实际解析语法。关于ruby-on-rails-Textmate'Gotosymbol
ruby-on-rails - Rails 存在吗？不区分大小写 - 2
Model.exists?("lower(email)=?",params[:email].downcase)返回错误:ArgumentError(参数数量错误(2代表0..1)):是否可以使用不区分大小写的匹配来执行exists?？最佳答案您需要做的就是:Model.exists?(["lower(email)=?",params[:email].downcase])它正在寻找一个参数，但您提供了两个。使用数组形式和查找式条件应该可以满足您的需求。关于ruby-on-rails-
ruby - 使用 Ruby 在数组中查找大小为 N 的所有子集 - 2
给定一个数组['a','b','c','d','e','f']，我如何获得包含两个的所有子集的列表、三、四元素？我是Ruby的新手(从C#迁移过来)，不确定“Ruby之道”是什么。最佳答案查看Array#combination然后是这样的:2.upto(4){|n|array.combination(n)} 关于ruby-使用Ruby在数组中查找大小为N的所有子集，我们在StackOverflow上找到一个类似的问题： https://stackoverf

go - 拉 0 大小的 golang chan

有关go - 拉 0 大小的 golang chan的更多相关文章

随机推荐