Hassan

yep 木头竹签削的

不会，刚好放下。
确实比较忙，进度慢了。杂事太多。

全靠想象力

对

待在家里

Java 在做这类事情上 还是感觉代码好多 哈哈

什么鬼

我也不造啊。。。。

阿里巴巴分享的 pdf 里面就是这样写的

纠正一下 take 漏了循环 ，只取了一次。。。。。。
public class BlockingQTest {
public static void main(String [] as) throws InterruptedException {
BlockingQ blockingQ = new BlockingQ();
Thread offerThread = new Thread(new OfferTask(blockingQ),"offerThread");
Thread takeThread = new Thread(new TakeTask(blockingQ),"takeThread");
offerThread.start();
takeThread.start();
}
}

class TakeTask implements Runnable{
	private BlockingQ blockingQ;
	public TakeTask(BlockingQ blockingQ){
		this.blockingQ = blockingQ;
	}
	@Override
  public void run() {
		try {
			while(true) {
				Object o = blockingQ.take();
				System.out.println("take：" + o);
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}
class OfferTask implements Runnable{
	private BlockingQ blockingQ;
	public OfferTask(BlockingQ blockingQ){
		this.blockingQ = blockingQ;
	}
	@Override
  public void run() {
		try {
			for (int i=0; i < 100; i++){
				blockingQ.offer(i);
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

我做了个测试：

public class BlockingQTest {
	public static void main(String [] as) throws InterruptedException {
		BlockingQ blockingQ = new BlockingQ();
		Thread offerThread = new Thread(new OfferTask(blockingQ), "offerThread");
		Thread takeThread = new Thread(new TakeTask(blockingQ), "takeThread");
		offerThread.start();
		takeThread.start();
	}
}

class TakeTask implements Runnable{
	private BlockingQ blockingQ;
	public TakeTask(BlockingQ blockingQ){
		this.blockingQ = blockingQ;
	}
	@Override
  public void run() {
		try {
			Object o = blockingQ.take();
			System.out.println("take：" + o);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}
class OfferTask implements Runnable{
	private BlockingQ blockingQ;
	public OfferTask(BlockingQ blockingQ){
		this.blockingQ = blockingQ;
	}
	@Override
  public void run() {
		try {
			for (int i=0; i < 100; i++){
				blockingQ.offer(i);
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

确实是不会释放锁的，我写的测试方式有问题吗 ？ 死锁了

那这个简单的阻塞队列实现就有问题了啊
offer 的 notEmpty 如果不会释放
那 take 如何进入 notEmpty 呢？

感谢分享~~~~ 哈哈哈

我最近两次公司内部换部门，感觉和离职的心情一样，哈哈哈哈

感觉 nodebb 也不错啊

可以作为一个补充 哈哈 谢谢

我是前端菜菜 我搞 Java 的 哈哈哈哈

是的 蛮好用的

修改网站内容利器 还有百度云下载的插件 百度去广告插件 都很好用

哈哈 你应该打赏我

好帖

还蛮有趣的

和业务逻辑没关系，你可以理解为要进入某个功能，必须先把用户信息去策略系统匹配一下，ok 才能进入。

我们是有一个策略系统的，策略系统可以配置用户的一些信息，比如男女、单双号、渠道（每个用户的渠道标识）等，然后匹配的才走某个逻辑，不匹配就不处理了。灰度完成，再把策略应用到全渠道，不过这是属于编码层面的控制。

朋友圈 算不算 哈哈

这个问题没有直接解决 只是换了个思路 不连远程了 呵呵

年底比较忙 年会包了一个迪厅 然后 各种节目 我们节目拿了一等奖 哈哈哈哈

我觉得考虑上次编辑比较合理

可是 1 分钟内扣了两次，是 bug 么？是不是要给我发现 bug 的奖励。哈哈哈