TtlRunnable是否可以支持PriorityQueue和DelayQueue

[simonHome]

TtlRunnable是否可以支持PriorityQueue和DelayQueue的Comparable task接口？

举个例子：

线程池使用PriorityQueue队列，然后execute(new PriorityTask())。

如果这个时候插桩是在execute时，PriorityTask将包装成TtlRunnable后offer到队列中基于PriorityQueue底层的Compare机制会将Runnable强转成Comparable接口进而出现异常。

是否有考虑过支持这种场景？

public static class PriorityTask implements Runnable, Comparable<PriorityTask> {
    private final int order;
    public PriorityTask(int order) {
        this.order = order;
    }

    @Override
    public int compareTo(PriorityTask o) {
        return Integer.compare(this.order, o.order);
    }

    @Overrid
    public void run() {
        System.out.println("测试执行" + order);
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
        }
    }
}

[oldratlee]

@simonHome

• TTL支持PriorityQueue。

  • 在v2.12.3实现，v2.12.5有这个功能的Bug Fix。
  • 
  • 你可以使用试试，推荐用TTL最新版本 💕
  • API方式使用Demo：TtlExecutorServiceWithPriorityBlockingQueueDemo
  • TTL Agent方式透明支持

• 还没有支持 DelayQueue。

  • 能说一下你的需求场景、使用方式吗？💕
  • 需要想想实现方式

[oldratlee]

@simonHome issue 先 close 了，有问题可以继续讨论～ 💕