如果 用户重写阻塞队列 offer方法，这种情况能够兼容么

[simake2017]

这里用户重写了一个阻塞队列，然后重写了put和offer方法，里面进行了强制转换，这种现在能兼容么

[oldratlee]

@simake2017 给一个可以说明/复现问题的、极简可运行的Demo工程：❤️

• 通过运行Demo可以演示出：
  • 没有使用TTL时，没有问题
  • 使用TTL时，出的是什么问题
• 提交成一个github repo，方便大家运行以了解问题与排查解决
• 推荐像这个Issue TTL agent 与 其他agent的兼容性问题 #226 (comment) 给的工程 liauraljl/ttl-agent-demo

---

PriorityBlockingQueue的问题

• 在版本v2.12.3中 支持了：
  https://github.com/alibaba/transmittable-thread-local/releases/tag/v2.12.3
• 对应Issue： ClassCastException(TtlRunnable cannot be cast to Comparable) when use PriorityBlockingQueue with ThreadPoolExecutor #330

[simake2017]

是这样的：

• 用户自己写了一个阻塞队列，然后在创建ThreadPoolExecutor的时候，使用了自己的阻塞队列
• 阻塞队列中，又重写了put以及offer方法，方法内容如上图，里面会进行强转
  • 也就是将TtlRunnable转为自己的Runnable子类
  • 就会爆出ClassCastException

可运行demo，稍后给出，问题应该比较清楚的

[oldratlee]

编码的解决方法，已经有支持的：

对Runnable参数 先做TtlRunnable.unwrap(runnable)。

@simake2017 应该是你说的兼容，兼容这样的使用方式？

演示Demo

写了一个说明问题的、极简可运行的Demo，在分支dev-2.12.x上： @simake2017

transmittable-thread-local/src/test/java/com/alibaba/demo/ttl/CustomizedBlockingQueueWithTtlDemo.java

Lines 51 to 82 in 004668d

	@Override
	public boolean offer(final Runnable runnable) {
	// unwrap TtlRunnable first
	final Runnable unwrap = TtlRunnable.unwrap(runnable);
	final MyTask myTask = (MyTask) unwrap;
	if (myTask.msg.startsWith("accept-")) {
	// ignore result/return value of offer, BAD!!
	// does not follow the contract of method offer
	// this is just a simple demo!
	super.offer(runnable);
	}
	// always return true even if discard the task, BAD!!
	// does not follow the contract of method offer
	// this is just a simple demo!
	return true;
	}
	@Override
	public void put(final Runnable runnable) throws InterruptedException {
	// unwrap TtlRunnable first
	final Runnable unwrap = TtlRunnable.unwrap(runnable);
	final MyTask myTask = (MyTask) unwrap;
	// discard task if not satisfied, BAD!!
	// does not follow the contract of method put
	// this is just a simple demo!
	if (myTask.msg.startsWith("accept-")) {
	super.put(runnable);
	}
	}

关于系统设计的讨论

就像代码注释中所说的，

transmittable-thread-local/src/test/java/com/alibaba/demo/ttl/CustomizedBlockingQueueWithTtlDemo.java

Lines 56 to 67 in 004668d

	final MyTask myTask = (MyTask) unwrap;
	if (myTask.msg.startsWith("accept-")) {
	// ignore result/return value of offer, BAD!!
	// does not follow the contract of method offer
	// this is just a simple demo!
	super.offer(runnable);
	}
	// always return true even if discard the task, BAD!!
	// does not follow the contract of method offer
	// this is just a simple demo!
	return true;

• 丢弃任务、忽略真实的返回结果（任务是否提交成功了）的做法是有问题的：
  不符合BlockingQueue接口方法的契约。
• 结果可能会带来各种细节、下层基础的问题（挖坑了）！ 💣 💥

这可能是 平时我们几乎没有看到定制/继承BlockingQueue 的原因。 @simake2017

看起来，像任务过滤这样的业务逻辑：

• 应该在上层的线程池中（比如wrapper、AOP线程池）完成，
• 而不是定制下层的BlockingQueue但打破了BlockingQueue接口方法契约的方式来实现。

[oldratlee]

@simake2017 这个 Issue 先 close。如果还有问题，可以继续讨论。