public <T> void addQueue(T t, long delayTime, TimeUnit timeUnit,String queueName){ // 定义阻塞队列list RBlockingDeque<T> blockingDeque = redissonClient.getBlockingDeque(queueName); // 定义延迟队列 RDelayedQueue<T> delayedQueue = redissonClient.getDelayedQueue(blockingDeque); // 把元素放入延迟队列 delayedQueue.offer(t,delayTime,timeUnit); }

这段代码是用 Redisson 实现的一个通用的延迟队列的添加方法。其中，Redisson 是一个基于 Redis 的 Java 库，提供了分布式锁、分布式对象、分布式集合等功能。在这个方法中，通过 Redisson 的 API 获取到了一个阻塞队列和一个延迟队列，然后将元素放入延迟队列中，并指定了延迟时间和时间单位。这样，元素就会在指定的时间后自动从延迟队列中取出，添加到阻塞队列中，供其他线程消费。需要注意的是，该方法使用了泛型，可以支持任何类型的元素。