假设您在 Java 中有一个典型的生产者-消费者模式。为了提高效率，您希望在将新元素添加到队列时使用 notify() 而不是 notifyAll()。如果两个生产者线程调用通知，是否保证两个不同的等待消费者线程将被唤醒？或者可能是两个 notify() 相继触发导致同一个 comsumer 线程两次排队等待唤醒？我找不到该部分是描述其具体工作原理的 API。 java 是否有一些原子内部操作来唤醒线程一次？
如果只有一个消费者在等待，那么第二个通知就会丢失，这没问题。
最佳答案
我的回答包含一些特定于实现的信息。它基于我对 Sun JVM 和其他线程库行为的工作知识。
If two producer threads invoke notify, is it guaranteed that two distinct waiting consumer threads will be awoken?
不，不是。不能保证会有任何消费者被唤醒。可以保证的是，如果有 2 个线程在等待，那么 2 个不同线程将被放入运行队列。
Or can it be that two
notify()s fired shortly after each other cause the same comsumer thread to be queued for wakeup twice?
没有。两次 notify() 调用不会导致同一个消费者线程被排队两次。然而，它可能会导致一个线程被唤醒并且可能没有其他线程在等待，因此第二个 notify() 调用可能什么都不做。当然，线程可能已经被唤醒，然后马上返回等待，然后以这种方式获得第二个 notify() 调用，但我认为这不是您要问的。
Does java have some atomic internal operation for waking up threads exactly once?
是的。 Thread 代码有许多同步点。一旦一个线程被通知，它就会被移出 wait 队列。以后对 notify() 的调用将查看 wait 队列，但找不到线程。
还有一点重要。对于生产者/消费者模型，始终确保您在 while 循环中测试条件。原因是存在与锁上阻塞但未等待条件的消费者之间的竞争条件。
synchronized (workQueue) {
// you must do a while here
while (workQueue.isEmpty()) {
workQueue.wait();
}
workQueue.remove();
}
Consumer1 可能正在等待 workQueue。 Consumer2 可能在 synchronized 但在运行队列中被阻塞。如果将某些内容放入 workQueue 并调用 workQueue.notify()。 Consumer2 现在被放入运行队列，但落后 Consumer1 第一个。这是一个常见的实现。因此，Consumer1 会从 workQueue 中删除通知 Consumer2 的项目。 Consumer2 必须再次测试 workQueue 是否为空，否则 remove() 将抛出异常，因为队列再次为空。在这里查看 more details of the race .
同样重要的是要认识到虚假唤醒已被记录在案，因此 while 循环可以防止线程在没有 wait() 调用的情况下被唤醒。
综上所述，如果您可以按照其他答案中的建议使用 BlockingQueue 来减少生产者/消费者代码，那么您应该这样做。 BlockingQueue 代码已经解决了所有这些问题。
关于java - notify可以多次唤醒同一个线程吗？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10684111/
类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
我的代码目前看起来像这样numbers=[1,2,3,4,5]defpop_threepop=[]3.times{pop有没有办法在一行中完成pop_three方法中的内容？我基本上想做类似numbers.slice(0,3)的事情，但要删除切片中的数组项。嗯...嗯，我想我刚刚意识到我可以试试slice! 最佳答案 是numbers.pop(3)或者numbers.shift(3)如果你想要另一边。 关于ruby-多次弹出/移动ruby数组，我们在StackOverflow上找到一
使用带有Rails插件的vim，您可以创建一个迁移文件，然后一次性打开该文件吗？textmate也可以这样吗？ 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件，这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails，您可以创建一个新的迁移文件并一次性打开它吗？，我们在StackOverflow上找到一个类似的问题： https://sta
我需要从一个View访问多个模型。以前，我的links_controller仅用于提供以不同方式排序的链接资源。现在我想包括一个部分(我假设)显示按分数排序的顶级用户(@users=User.all.sort_by(&:score))我知道我可以将此代码插入每个链接操作并从View访问它，但这似乎不是“ruby方式”，我将需要在不久的将来访问更多模型。这可能会变得很脏，是否有针对这种情况的任何技术？注意事项:我认为我的应用程序正朝着单一格式和动态页面内容的方向发展，本质上是一个典型的网络应用程序。我知道before_filter但考虑到我希望应用程序进入的方向，这似乎很麻烦。最终从任何
我想要做的是有2个不同的Controller，client和test_client。客户端Controller已经构建，我想创建一个test_clientController，我可以使用它来玩弄客户端的UI并根据需要进行调整。我主要是想绕过我在客户端中内置的验证及其对加载数据的管理Controller的依赖。所以我希望test_clientController加载示例数据集，然后呈现客户端Controller的索引View，以便我可以调整客户端UI。就是这样。我在test_clients索引方法中试过这个:classTestClientdefindexrender:template=>
查看Ruby的CSV库的文档，我非常确定这是可能且简单的。我只需要使用Ruby删除CSV文件的前三列，但我没有成功运行它。 最佳答案 csv_table=CSV.read(file_path_in,:headers=>true)csv_table.delete("header_name")csv_table.to_csv#=>ThenewCSVinstringformat检查CSV::Table文档:http://ruby-doc.org/stdlib-1.9.2/libdoc/csv/rdoc/CSV/Table.html
设置:狂欢ruby1.9.2高线(1.6.13)描述:我已经相当习惯在其他一些项目中使用highline，但已经有几个月没有使用它了。现在，在Ruby1.9.2上全新安装时，它似乎不允许在同一行回答提示。所以以前我会看到类似的东西:require"highline/import"ask"Whatisyourfavoritecolor?"并得到:Whatisyourfavoritecolor?|现在我看到类似的东西:Whatisyourfavoritecolor?|竖线(|)符号是我的终端光标。知道为什么会发生这种变化吗？ 最佳答案
我发现ActiveRecord::Base.transaction在复杂方法中非常有效。我想知道是否可以在如下事务中从AWSS3上传/删除文件:S3Object.transactiondo#writeintofiles#raiseanexceptionend引发异常后，每个操作都应在S3上回滚。S3Object这可能吗？？ 最佳答案 虽然S3API具有批量删除功能，但它不支持事务，因为每个删除操作都可以独立于其他操作成功/失败。该API不提供任何批量上传功能(通过PUT或POST)，因此每个上传操作都是通过一个独立的API调用完成的
如果您尝试在Ruby中的nil对象上调用方法，则会出现NoMethodError异常并显示消息:"undefinedmethod‘...’fornil:NilClass"然而，有一个tryRails中的方法，如果它被发送到一个nil对象，它只返回nil:require'rubygems'require'active_support/all'nil.try(:nonexisting_method)#noNoMethodErrorexceptionanymore那么try如何在内部工作以防止该异常？ 最佳答案 像Ruby中的所有其他对象
关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗？通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串？SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复？