单/通量：如何挂起线程并等待事件或超时
谢谢。
共有1个答案
最后我找到了解决办法。
也许不是最优雅的，但工作，使用递归
此代码查询变量状态得到肯定的响应，但不超过10秒的超时。
val delayDuration = Duration.ofMillis(200)
val maximumAttempts = 50
fun createDelayedMono(counter : Int) : Mono<BigInteger> {
val mono = Mono.delay(delayDuration).flatMap {
it ->
if (counter < maximumAttempts && reactorHelper.isEventCompleted(rrn)) {
reactorHelper.removeEvent(rrn)
return@flatMap Mono.just(BigInteger.ZERO)
} else {
return@flatMap createDelayedMono(counter + 1)
}
}
return mono
}
-
问题内容： 我找不到如何测量线程等待锁定的时间。我必须确定一个线程是否正在等待锁定超过1秒，如果需要，则运行另一个线程。谢谢！ 问题答案： 试试这个：
-
我是一个初学者，我正在实施餐饮哲学家的问题。然而，我遇到了一个问题。在我的哲学家（）函数中，我希望我的其他线程等待，直到左右筷子都可以使用。我应该如何实现这一点？目前，该计划只是在两位哲学家吃完后终止，而不等待其他人吃完 我已经试过了： 使用互斥锁来锁定哲学家（）函数中的共享变量，虽然可以确保没有哲学家挨饿，但使用这种方法意味着放弃并发（即使有筷子可供其他哲学家使用，一次也只能有一位哲学家吃饭）
-
按下按钮后，我的界面冻结。我使用线程，但我不知道为什么仍然挂起。任何帮助都将不胜感激。提前谢谢
-
问题内容： 在这里，我想每秒钟调用一次“ Log.d”和“ postInvalidate”。但是，当我从LogCat检查它时，似乎循环运行的速度比我希望的要快。为什么这个循环不等待1000ms？ 以下是LogCat中的输出。因此，您可以看到它根本没有休眠1秒钟。我也使用了Thread.sleep（在您建议之后） 这是最新的代码。是布尔值，现在是事实。 输出是 问题答案： 您需要类的方法。 使发送此
-
问题内容： 我正在为我的ubuntu服务器（针对我的多客户端匿名聊天程序）实现一种简单的线程池机制，并且需要使我的工作线程进入睡眠状态，直到需要执行一项工作（以函数指针和参数的形式） 。 我当前的系统即将关闭。我（工人线程正在）问经理是否有工作可用，以及是否有5毫秒没有睡眠。如果存在，请将作业添加到工作队列中并运行该函数。糟糕的循环浪费。 什么我 喜欢 做的是做一个简单的事件性的系统。我正在考虑有
-
我是多线程的新手，当我阅读有关多线程的内容时，我想编写这个精美的多线程代码来执行以下操作。 我的柜台类如下。 这个计数器对象由两个线程共享。一旦线程启动，我需要做以下事情。我希望Thread2一直等到Thread1将Counter对象的计数加1。完成后，线程1通知线程2，然后线程1开始等待线程2将值递减1。然后，线程2启动并将值递减1，并再次通知线程1，然后线程2开始等待线程1。重复这个过程几次。