利用循环确保队列有东西的情况才取值，导致 CPU 100% 占用

[iwdmb]

大家好，目前遇到了一个问题，苦思許久没有比较好的解法。

我有一个队列，想要确保其里面有东西的情况，才将其取出并删除，必须要是线程安全的。

while (true) {
	if deque.length() > 0 {
		// deque.popBack
	}
    
    // sleep
}

这段代码在 deque.length() 一直为 0 的时候，会导致 CPU 占用 100%。

想询问除了加上 sleep 有没有比较好的作法。

谢谢大家！

P.s. 在 Golang 可以透过 Channel 解决这个问题，不过 Channel 本身涉及到了 runtime 的调度，想知道在其他语言 例如 Java or C++ 是如何解决这个问题的。

[araaaa]

用单线程池做定时任务

[iwdmb]

@araaaa
可能是我描述的不清楚
我主要是想解决在没有延迟的情况处理 deque 中的资料
同时避免 CPU 100% 的问题

[iwdmb]

sleep 只是其中一个解法，可是我希望可以做到不要延迟的处理 deque

[litmxs]

入队的时候唤醒线程？

[araaaa]

@iwdmb #2 调度周期间隔可以定位毫秒或者微秒

[luckyrayyy]

Java 里面有很多现成的实现，队里为空的时候线程就阻塞了。

[iwdmb]

@litmxs 與 Golang Channel 的原理其實很相似了。

[gaobing]

生产者消费者是任何语言的并发或者多线程编程的入门例子吧。。。看你写的像 Java，Java 里面 wait notify 配套，await signal 配套，或者 BlockingQueue 都可以。

[iwdmb]

@luckyrayyy 看起来思路都是类似的，不知道能不能请前辈推荐 Java 开源项目有類似的實現，感谢。
或是有什么关键字之类的。

[iwdmb]

@gaobing 看起来就是 BlockingQueue，实在是见识浅薄，真的非常感谢。

[luckyrayyy]

@iwdmb TransferQueue，LinkedBlockingQuque，ArrayBlockingQueue 。

[iwdmb]

@gaobing @luckyrayyy 多谢两位前辈，原来是生产者消费者唤醒问题这么基础大学就学过的案例，回头要再去复习一下恐龙书。

[crella]

不如定义一个 Deque 类，它的实例变量 data 和 waitlist 是两个数组，类有 add()和 out_call()方法。

外部通过 Deque.add(obj)方法来给 deque 队列添加元素，也就是添加到 data 数组里。然后 add()方法快结束时给 waitlist 添加所有在 data 里的对象，然后新建线程执行 out_call()方法。

out_call()方法执行时，新建数组 currentlist=waitlist 深拷贝，然后逐个对应删除 waitlist 内的对象，然后遍历本函数内的 currentlist 执行外部函数操作即可。

我不会协程，只会简单的多线程操作。上面涉及到 data 和 waitlist 的注意加好互斥锁。


其实说简陋点，像 windows 窗口，点击一下按钮就有反应，实际上是 window UI 线程在主循环，而不是外部函数在循环检查 win UI 线程。把 Deque 类当作 win UI 线程应该可以。实际上听说 winform 程序都是把 UI 当做主线程的。再说得简单点就是把 Deque 类当成数组并给它加一个“点击按钮”后的操作，这里的“点击按钮”应该就是多线程往数组添加吧。

我之前想给 ruby 的 Array 也添加一个操作，让它被添加元素后自动执行操作。后来想一下还是用类似上面的 Deque 类包装一个类型为 Array 的实例变量好了。


以上都未经验证，纯属猜想。

[hsyu53]

c++的话，可以用 mutex + condition variable

[Mithril]

直接用 ReactiveX 就好了，响应式的思路明显更简单。
虽说实际上也是开了线程处理吧。

[45HXlKzal6W56zUJ]

为啥不直接 Queue.get()呢
默认就是 block 永不超时

[45HXlKzal6W56zUJ]

哦,你这不是 python..