Tag: 未来

kotlin协程 – 阻塞线程，直到收到超时或消息计数

使用Kotlin，我会阻塞一个线程，直到从回调MessageBroker收到n条消息（或发生超时）; 例如 – 类似的东西; fun receivedMessages(numberOfMessages: Int, timeout: Long): List { receivedMessages: ArrayList //subscribe to a queue and get a callback for EACH message on the queue eg //listen until the ‘numberOfMessages’ have been reveived OR the timeout is reached. eg async – block { messageQueue.setMessageListener (message -> { receivedMessages.add(message) if (receivedMessages.size > numberOfMessages) //break […]