java多线程复习与巩固（六）

手动实现一个LUR

LRU全称是Least Recently Used，即最近最久未使用的意思

package com.gooagoo.market.common.util;import java.util.PriorityQueue;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/*** Created by zhangkun on 2020/5/23.*/
public class LUR {private static ScheduledExecutorService scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(10);private static ConcurrentHashMap<String,Node> cache = new ConcurrentHashMap<>(1024);private static PriorityQueue<Node> expireQueue = new PriorityQueue(1024);public LUR(){scheduledThreadPoolExecutor.scheduleWithFixedDelay(new ExpireNode(),3,3, TimeUnit.SECONDS);}public class ExpireNode implements  Runnable{@Overridepublic void run() {//获取当前时间long curTime= System.currentTimeMillis();while(true){Node node = expireQueue.peek();// 队列获取头部元素 为空  或者不过期则返回if(node == null||node.getExpireTime()>curTime){return;}// 过期则从缓存中删除 并且从队列中弹出cache.remove(node.getKey());expireQueue.poll();}}}public Object set(String key,Object value,long ttl){//获取过期时间点long expireTime = System.currentTimeMillis()+ttl;Node newNode = new Node(key,value,expireTime);Node oldNode = cache.get(key);//cache 有的话就覆盖 没有的话就添加新的cache.put(key,newNode);expireQueue.offer(newNode);if(oldNode!=null){expireQueue.remove(oldNode);return oldNode.getValue();}return  null;}public Object get(String key){Node node = cache.get(key);if(node!=null){return node.getValue();}return null;}}

package com.gooagoo.market.common.util;import org.apache.xmlbeans.impl.xb.xsdschema.Public;/*** Created by zhangkun on 2020/5/23.*/
public class Node implements Comparable<Node> {public String getKey() {return key;}public void setKey(String key) {this.key = key;}public Object getValue() {return value;}public void setValue(Object value) {this.value = value;}public long getExpireTime() {return expireTime;}public void setExpireTime(long expireTime) {this.expireTime = expireTime;}private String key;private Object value;private long expireTime;public Node(String key,Object value,long expireTime) {this.key = key;this.value = value;this.expireTime = expireTime;}@Overridepublic int compareTo(Node o) {long time = this.expireTime - o.expireTime;if(time>0){return 1;}if(time<0){return -1;}return 0;}
}

java多线程复习与巩固（六）相关推荐

Java多线程复习_Java多线程复习
一.线程的基本概念简单的说:线程就是一个程序里不同的执行路径在同一个时间点上cpu只会有一个线程在执行 Java里的多线程是通过java.lang.Thread类来实现的每个线程都拥有自己独立的 ...
Java多线程学习三十六：主内存和工作内存的关系
CPU 有多级缓存,导致读的数据过期由于 CPU 的处理速度很快,相比之下,内存的速度就显得很慢,所以为了提高 CPU 的整体运行效率,减少空闲时间,在 CPU 和内存之间会有 cache 层,也就 ...
Java多线程学习二十六：原子类是如何利用 CAS 保证线程安全的？
什么是原子类,以及它有什么作用. 在编程领域里,原子性意味着"一组操作要么全都操作成功,要么全都失败,不能只操作成功其中的一部分".而 java.util.concurrent.a ...
Java多线程复习：5（sleep、yield方法和线程优先级）
sleep.yield方法和线程优先级 sleep方法调用 sleep 会让当前线程从 Running 进入 Timed Waiting 状态(阻塞): 其它线程可以使用 interrupt 方法打 ...
Java多线程复习：3（在操作系统中查看和杀死进程线程）
此博客是记录自己学习过程的记录,仅做参考 Windows下查看和杀死进程线程查看所有进程 tasklist 查看指定关键字的进程 tasklist | findstr + 关键字 Java程序运行的 ...
Java多线程复习：2（线程的创建和使用）
线程的创建和使用方法一,直接使用Thread import lombok.extern.slf4j.Slf4j; /*** @author:小关同学爱吃汉堡* @date: 2021/4/1 23: ...
Java多线程复习：1（进程和线程、并发和并行）
进程和线程进程我们电脑中每一个运行着的程序都是一个进程,程序一旦运行就是进程. 进程可以视为程序的一个实例,大部分程序可以同时运行多个实例进程(如:浏览器.记事本.画图等),也有的程序只能启动一个 ...
Java多线程复习整理（二）
目录 1. 线程的五种状态(操作系统层面)? 2.线程的状态(JAVA层面)? 3.. 线程相关的基本方法? 4. wait()和sleep()的区别? 5.sleep()方法和yield()方法区别 ...
java多线程复习与巩固（三）
Java中线程的状态分为6种. 新建(NEW):新创建的一个线程对象. 可运行(RUNNABLE):也叫就绪状态.线程对象创建后,其他线程(比如main线程)调用该线程的start 方法.该状态的线程 ...

java多线程复习与巩固（六）

java多线程复习与巩固（六）相关推荐

最新文章

热门文章