第java固定大小隊列的幾種實現(xiàn)方式詳解ListOperationsString,IntegerstringIntegerListOperations=redisTemplate.opsForList();

//LPUSH操作

stringIntegerListOperations.leftPush(REDIS_LIST_KEY,MOCK_EXCEPTION_COUNT);

//LTRIM

stringIntegerListOperations.trim(REDIS_LIST_KEY,0,LIST_SIZE-1);

//LRANGE操作

ListIntegerrange=stringIntegerListOperations.range(REDIS_LIST_KEY,0,LIST_SIZE-1);

//對結(jié)果操作

size=range.size();

sum=range.stream().mapToInt(value-value).sum();

完整示例

@Service

@Slf4j

publicclassFixedListScheduler{

privatestaticfinalintLIST_SIZE=10;

privatestaticfinalintMOCK_EXCEPTION_COUNT=1;

privatestaticfinalStringREDIS_LIST_KEY="redis_fixed_list";

privatefinalFixedLinkedHashMapString,IntegerfixedLinkedHashMap=newFixedLinkedHashMap(LIST_SIZE);

privatefinalEvictingQueueIntegerevictingQueue=EvictingQueue.create(LIST_SIZE);

@Resource

privateRedisTemplateString,IntegerredisTemplate;

@Scheduled(cron="*/1****")

publicvoidschedule(){

fixedLinkedHashMap.put(UUID.randomUUID().toString(),MOCK_EXCEPTION_COUNT);

longsize=fixedLinkedHashMap.values().size();

intsum=fixedLinkedHashMap.values().stream().mapToInt(value-value).sum();

("fixedLinkedHashMapsize:{},sum:{}",size,sum);

evictingQueue.add(MOCK_EXCEPTION_COUNT);

size=evictingQueue.size();

sum=evictingQueue.stream().mapToInt(value-value).sum();

("evictingQueuesize:{},sum:{}",size,sum);

ListOperationsString,IntegerstringIntegerListOperations=redisTemplate.opsForList();

stringIntegerListOperations.leftPush(REDIS_LIST_KEY,MOCK_EXCEPTION_COUNT);

stringIntegerListOperations.trim(REDIS_LIST_KEY,0,LIST_SIZE-1);

ListIntegerrange=stringIntegerListOperations.range(REDIS_LIST_KEY,0,LIST_SIZE-1);

if(!CollectionUtils.isEmpty(range)){

sum=range.stream().mapToInt(value-value).sum();

("redisFixedListsize:{},sum:{}",range.size(),sum);

程序啟動一段時間后的日志，可以看到是滿足要求的。

2025-07-1218:35:29.006INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:evictingQueuesize:10,sum:10

2025-07-1218:35:29.009INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:redisFixedListsize:10,sum:10

2025-07-1218:35:30.002INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:fixedLinkedHashMapsize:10,sum:10

2025-07-1218:35:30.002INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:evictingQueuesize:10,sum:10

2025-07-1218:35:30.005INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:redisFixedListsize:10,sum:10

2025-07-1218:35:31.005INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:fixedLinkedHashMapsize:10,sum:10

2025-07-1218:35:31.005INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:evictingQueuesize:10,sum:10

2025-07-1218:35:31.008INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:redisFixedListsize:10,sum:10

2025-07-1218:35:32.005INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:fixedLinkedHashMapsize:10,sum:10

2025-07-1218:35:32.005INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:evictingQueuesize:10,sum:10

2025-07-1218:35:32.009INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:redisFixedListsize:10,sum:10

2025-07-1218:35:33.002INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:fixedLinkedHashMapsize:10,sum:10

2025-07-1218:35:33.002INFO8622---[pool-2-thread-1]com.yichao.myblogs.FixedListScheduler:evictingQueuesize:10,sum:10

2025-07-1218:35:33.005INFO8622---[pool-2-th