数据砖 店面 ng

您好！
本帖隐藏的内容需要积分高于 100 才可浏览
您当前积分为 0。
使用VIP即刻解锁阅读权限或查看其他获取积分的方式

游客，您好！
本帖隐藏的内容需要积分高于 100 才可浏览
您当前积分为 0。
VIP即刻解锁阅读权限 或 查看其他获取积分的方式
Unlock interview details and practice with AI
Curated Interview Questions from Top Companies

您好！
本帖隐藏的内容需要积分高于 100 才可浏览
您当前积分为 0。
使用VIP即刻解锁阅读权限或查看其他获取积分的方式

游客，您好！
本帖隐藏的内容需要积分高于 100 才可浏览
您当前积分为 0。
VIP即刻解锁阅读权限 或 查看其他获取积分的方式
Unlock interview details and practice with AI
Curated Interview Questions from Top Companies

匿名者 发表于 2021-10-11 15:58
Use a ring buffer to hold per-second counter in the past 5 mins. For example:

这个不对呀，比如说很长一段时间没有任何操作，load应该是0

1. import org.junit.jupiter.api.Assertions;
   
2. import org.junit.jupiter.api.Test;
   
3. 
   
4. import java.util.HashMap;
   
5. import java.util.LinkedHashMap;
   
6. import java.util.Map;
   
7. 
   
8. public class KeyValueStoreWithTime {
   
9.     private final Map<String, String> kv = new HashMap<>();
   
10.     private final LinkedHashMap<Long, Integer> getMetrics = new LinkedHashMap<>();
    
11.     private final LinkedHashMap<Long, Integer> putMetrics = new LinkedHashMap<>();
    
12.     private final int interval = 300;
    
13. 
    
14.     public String get(String key, long currentTime) {
    
15.         String value = kv.get(key);
    
16.         // long currentTime = System.currentTimeMillis() / 1000;
    
17.         getMetrics.merge(currentTime, 1, Integer::sum);
    
18.         truncateMetricsMap(getMetrics, currentTime, interval);
    
19.         return value;
    
20.     }
    
21. 
    
22.     public void put(String key, String value, long currentTime) {
    
23.         kv.put(key, value);
    
24.         // long currentTime = System.currentTimeMillis() / 1000;
    
25.         putMetrics.merge(currentTime, 1, Integer::sum);
    
26.         truncateMetricsMap(putMetrics, currentTime, interval);
    
27.     }
    
28. 
    
29.     public int getMetrics() {
    
30.         return getMetrics.values().stream().mapToInt(Integer::intValue).sum();
    
31.     }
    
32. 
    
33.     public int putMetrics() {
    
34.         return putMetrics.values().stream().mapToInt(Integer::intValue).sum();
    
35.     }
    
36. 
    
37.     private void truncateMetricsMap(LinkedHashMap<Long, Integer> metricsMap, long currentTime, int interval) {
    
38.         metricsMap.entrySet().removeIf(longIntegerEntry -> longIntegerEntry.getKey() < currentTime - interval);
    
39.     }
    
40. 
    
41.     @Test
    
42.     public void testKeyValueStoreWithTime() {
    
43.         put("1", "v", 1);
    
44.         put("2", "v", 100);
    
45.         put("3", "v", 200);
    
46.         put("4", "v", 200);
    
47.         put("5", "v1", 400);
    
48.         put("5", "v2", 400);
    
49.         put("6", "v", 500);
    
50. 
    
51.         Assertions.assertEquals(5, this.putMetrics());
    
52.     }
    
53. }

复制代码

我的想法是用一个LinkedHashMap记录put和get操作的次数，因为Java 的LinkedHashMap是按照key的插入时间有序的，每次put/get操作完，只要遍历一下这个LinkedHashMap，把300s之前的记录全部删掉。需要返回put/get统计的时候，把这个LinkedHashMap的值sum一下即可

觉得有帮助请加点米

请问这道题需要我们从头design hashmap吗，比如 LC 706, 还是我们可以调用java已有的hashmap？谢谢啦

您好！
本帖隐藏的内容需要积分高于 100 才可浏览
您当前积分为 0。
使用VIP即刻解锁阅读权限或查看其他获取积分的方式

游客，您好！
本帖隐藏的内容需要积分高于 100 才可浏览
您当前积分为 0。
VIP即刻解锁阅读权限 或 查看其他获取积分的方式
Unlock interview details and practice with AI
Curated Interview Questions from Top Companies

dtccx 发表于 2022-8-6 22:40
感觉不太对，应该把truncateMetricsMap放在getMetrics()和putMetrics()里面的，如果在第0秒call了一次put ...

你可以putMetrics之前先更新下queue，把5分钟之前的全都pop queue