草庐IT

concurrency - 缓冲 channel 关闭 TRUE？

coder 2024-07-08 原文

我有一些问题......关于缓冲 channel

Q1.

那为什么 NonBuffered 永远不会输出 TRUE 值？

这是否意味着无缓冲 channel 总是关闭的？ 那为什么无缓冲 channel 仍然产生正确的斐波那契计算结果？

Q2.

为什么 NonBuffered 输出像下面这样在中间被切断？

    0 1 1 2 NB value: 0
    NB ok: false
    3

应该是goroutine相关的东西，为什么会这样？

这很难理解，因为如果我缓冲这个 channel ，我会得到真正的值(value)，但对于无缓冲的 channel ，我只会得到错误的...

请查看以下链接。

http://play.golang.org/p/O2Th61DfEY 

package main

import "fmt"

func main() {
  ch := make(chan int)

  go NB(5, ch)
  for i := range ch {
    fmt.Printf("%d ", i)
  }
  /*
    0 1 1 2 NON_Buffered value: 0
    NON_Buffered ok: false
    3
  */

  fmt.Println()
  value, ok := <-ch
  fmt.Println("MAIN = NB value:", value)
  fmt.Println("MAIN = NB ok:", ok)
}

func NB(n int, ch chan int) {
  x, y := 0, 1
  for i := 0; i < n; i++ {
    ch <- x
    x, y = y, x+y
  }
  close(ch)
  value, ok := <-ch
  fmt.Println("NB value:", value)
  fmt.Println("NB ok:", ok)
}

非常感谢!

最佳答案

Q1:你从不做value, ok <- ch在未关闭的 channel 上:在 NB 中，您在关闭后执行此语句 ch ，并且在 main 中，您在 for 循环中从 ch 读取所有内容后执行它。你为什么期望返回ok==true表示 channel 未关闭？

Q2:一旦 3 在 main 中从 ch 消耗掉，NB 可能会在 main 开始打印之前再次运行并打印。 NB 和 main 之间绝对没有同步。再次强调:您对这样的代码有什么期望？

如果你想模拟一个斐波那契数的生成器，你应该不从 ch 中读入 NB。这与缓冲无关。缓冲 channel 只允许一些 goroutine 在阻塞 channel 发送之前执行更长时间。

关于concurrency - 缓冲 channel 关闭 TRUE？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/20668506/

concurrencychannelvaluesectiongobuffer

有关concurrency - 缓冲 channel 关闭 TRUE？的更多相关文章

  1. ruby - 如何关闭 ruby​​ gem "Spreadsheet?"中的文件 - 2

    下面的代码在我第一次运行它时就可以正常工作:require'rubygems'require'spreadsheet'book=Spreadsheet.open'/Users/me/myruby/Mywks.xls'sheet=book.worksheet0row=sheet.row(1)putsrow[1]book.write'/Users/me/myruby/Mywks.xls'当我再次运行它时，我会收到更多消息，例如:/Library/Ruby/Gems/1.8/gems/spreadsheet-0.6.5.9/lib/spreadsheet/excel/reader.rb:11

  2. ruby - 使用 Ruby，计算 n x m 数组的每一列中有多少个 true 的简单方法是什么？ - 2

    给定一个nxmbool数组:[[true,true,false],[false,true,true],[false,true,true]]有什么简单的方法可以返回“该列中有多少个true？”结果应该是[1,3,2] 最佳答案 使用转置得到一个数组，其中每个子数组代表一列，然后将每一列映射到其中的true数:arr.transpose.map{|subarr|subarr.count(true)}这是一个带有inject的版本，应该在1.8.6上运行，没有任何依赖:arr.transpose.map{|subarr|subarr.in

  3. ruby-on-rails - Ruby 的 'open_uri' 是否在读取或失败后可靠地关闭套接字？ - 2

    一段时间以来，我一直在使用open_uri下拉ftp路径作为数据源，但突然发现我几乎连续不断地收到“530抱歉，允许的最大客户端数(95)已经连接。”我不确定我的代码是否有问题，或者是否是其他人在访问服务器，不幸的是，我无法真正确定谁有问题。本质上，我正在读取FTPURI:defself.read_uri(uri)beginuri=open(uri).readuri=="Error"?nil:urirescueOpenURI::HTTPErrornilendend我猜我需要在这里添加一些额外的错误处理代码...我想确保我采取一切预防措施来关闭所有连接，这样我的连接就不是问题所在，但是我

  4. ruby - Faye WebSocket，关闭处理程序被触发后重新连接到套接字 - 2

    我有一个super简单的脚本，它几乎包含了FayeWebSocketGitHub页面上用于处理关闭连接的内容:ws=Faye::WebSocket::Client.new(url,nil,:headers=>headers)ws.on:opendo|event|p[:open]#sendpingcommand#sendtestcommand#ws.send({command:'test'}.to_json)endws.on:messagedo|event|#hereistheentrypointfordatacomingfromtheserver.pJSON.parse(event.d

  5. ruby - 如何在 watir 测试套件结束时关闭浏览器？ - 2

    使用ruby​​的watir测试网络应用程序时，浏览器最后会保持打开状态。网上的一些建议是，要进行真正的单元测试，您应该在每次测试时(在拆卸调用中)打开和关闭浏览器，但这很慢而且毫无意义。或者他们做这样的事情:defself.suites=superdefs.afterClass#Closebrowserenddefs.run(*args)superafterClassendsend但这会导致摘要输出不再显示(诸如“100次测试、100次断言、0次失败、0次错误”之类的内容仍应显示)。我怎样才能让ruby​​或watir在我的测试结束时关闭浏览器？ 最佳答案

  6. ruby-on-rails - 如何在一段时间后关闭 Rails 闪现消息？ - 2

    我想设置秒数aflash在自动关闭之前向用户显示通知。 最佳答案 您可以在页面上使用一些简单的JavaScript(在此示例中使用jQuery):$('document').ready(function(){setTimeout(function(){$('#flash').slideUp();},3000);});假设保存您的flash消息的HTML元素的id是#flash，这将向上滑动并在3000毫秒(3秒)后将其隐藏。 关于ruby-on-rails-如何在一段时间后关闭Rails

  7. ruby-on-rails - 如何在关闭 cache_classes 的情况下使用来自中间件的域对象？ - 2

    在rails开发环境中，cache_classes是关闭的，所以你可以修改app/下的代码，不用重启服务器就可以看到变化。不过，在所有环境中，中间件只会创建一次。所以如果我有这样的中间件:classMyMiddlewaredefinitialize(app)@app=appenddefcall(env)env['model']=MyModel.firstendend我在config/environments/development.rb中执行此操作:config.cache_classes=false#thedefaultfordevelopmentconfig.middleware.

  8. ruby - 重新连接 tcpsocket(或如何检测已关闭的套接字) - 2

    我有一个连接到服务器的ruby​​tcpsocket客户端。在发送数据之前如何检查套接字是否已连接？我是否尝试“拯救”断开连接的tcpsocket，重新连接然后重新发送？如果是这样，有没有人有一个简单的代码示例，因为我不知道从哪里开始:(我很自豪我设法在rails中获得了一个持久连接的客户端tcpsocket。然后服务器决定杀死客户端，一切都崩溃了；)编辑我已经使用此代码解决了一些问题-如果未连接，它将尝试重新连接，但如果服务器已关闭则不会处理这种情况(它将继续重试)。这是正确方法的开始吗？谢谢defself.write(data)begin@@my_connection.write(

  9. ruby-on-rails - 我将 Rails3 与 tinymce 一起使用。如何呈现用户关闭浏览器javascript然后输入xss？ - 2

    我有一个用Rails3编写的站点。我的帖子模型有一个名为“内容”的文本列。在帖子面板中，html表单使用tinymce将“content”列设置为textarea字段。在首页，因为使用了tinymce，post.html.erb的代码需要用这样的原始方法来实现。.好的，现在如果我关闭浏览器javascript，这个文本区域可以在没有tinymce的情况下输入，也许用户会输入任何xss，比如alert('xss');.我的前台会显示那个警告框。我尝试sanitize(@post.content)在posts_controller中，但sanitize方法将相互过滤tinymce样式。例如

  10. ruby-on-rails - Rails add_index 算法 : :concurrently still causes database lock up during migration - 2

    为了防止在迁移到生产站点期间出现数据库事务错误，我们遵循了https://github.com/LendingHome/zero_downtime_migrations中列出的建议。(具体由https://robots.thoughtbot.com/how-to-create-postgres-indexes-concurrently-in概述)，但在特别大的表上创建索引期间，即使是索引创建的“并发”方法也会锁定表并导致该表上的任何ActiveRecord创建或更新导致各自的事务失败有PG::InFailedSqlTransaction异常。下面是我们运行Rails4.2(使用Acti

随机推荐