[面试题]java高性能的多计数器
admin
2024-05-13 12:16:14
0

题目要求

需要实现一个并发安全的多计数器,可以记录不同数字出现的次数,简单而言就是类似于 Map 的数据结构,但该数据结构所占用的内存较大:一个 Node 对象就需要占用 96Byte,如果算上 Node[] 则该数据结构整体的内存占用将是非常可观的。

综上所述,我们需要实现一个低内存开销并发安全的多计数器 MultiAtomicInteger:

public interface MultiAtomicInteger {/*** 原子的将 key 对应的值加上 cnt, 并返回更新后的值** @param key : 非负整数,取值范围为 [0 ~ Integer.MAX_VALUE]* @param cnt : 增量(正数)* @return : 更新后的值*/int addAndGet(int key, int cnt);/*** 返回 key 对应的值** @param key : 非负整数,取值范围为 [0 ~ Integer.MAX_VALUE]* @return : key 对应的值*/int get(int key);/*** 返回当前一共有多少 key*/int size();
}

为了降低编程难度,只需要实现一个无需扩容的 MultiAtomicInteger 即可,该类的构造函数需要指定最大容量。

答案:

public class MyMultiAtomicInteger implements MultiAtomicInteger {/*** lock集合*/private final Object[] locks;/*** [hash]*/private final long[][] map;/*** 0有特殊含义,单独用一个变量记*/private final AtomicInteger zeroNum = new AtomicInteger();/*** 标记0是否放入过*/private final AtomicBoolean existsZero = new AtomicBoolean();private final AtomicInteger size = new AtomicInteger();public ZslMultiAtomicInteger(int capacity) {// 系数越大,吞吐量越高,内存也越多
//        capacity = (int) Math.max(1, capacity * 0.35);capacity = (int) Math.max(1, capacity * 0.4);// 理论上锁数量越多,吞吐量越高,但是太多的话,占用内存也多int lockNum = Math.min(128, capacity);locks = new Object[lockNum];for (int i = 0; i < locks.length; i++) {locks[i] = new Object();}map = new long[capacity][];}@Overridepublic int addAndGet(int key, int cnt) {if (key == 0) {cnt = zeroNum.addAndGet(cnt);boolean exists = existsZero.getAndSet(true);if (!exists) {size.incrementAndGet();}return cnt;}int hash = hash(key);int lockIndex = hash % locks.length;synchronized (locks[lockIndex]) {long[] arr = map[hash];if (arr == null) {arr = map[hash] = new long[2]; // 初始化链表大小2}for (int i = 0; i < arr.length; i++) {if (arr[i] == 0) {arr[i] = createNode(key, cnt);size.incrementAndGet();return cnt;}if (key == getKey(arr[i])) {arr[i] += cnt;return getValue(arr[i]);}}int oldLen = arr.length;arr = map[hash] = Arrays.copyOf(arr, Math.min(arr.length << 1, Integer.MAX_VALUE));arr[oldLen] = createNode(key, cnt);size.incrementAndGet();return cnt;}}@Overridepublic int get(int key) {if (key == 0) {return zeroNum.get();}int hash = hash(key);long[] arr = map[hash];if (arr == null) {return 0;}for (long node : arr) {if (node == 0) {return 0;}if (key == getKey(node)) {return getValue(node);}}return 0;}@Overridepublic int size() {return size.get();}private int hash(int key) {return key % map.length;}private long createNode(int key, int value) {return (long) key << 32 | value;}private int getKey(long node) {return (int) (node >> 32);}private int getValue(long node) {return (int) (node);}
}

我遇到问题:

  • 如何更省空间的保存呢,如果用数组,那如何根据Key->数组下标呢,如果还做一个map映射,那就没有空间的意义了?
  • 如何设计一个key维度的锁?

解读:(例如1000个key,capacity=1000)

  • 存储结构:使用long[][] map二维数组存储,根据key%map.length得到二维数组的行下标。一维数组中单个元素是long类型,高位存int类型的Key,低位存int类型Value。一维数组中存储的是所有行下标的相同的元素。例如(1和401的对应的下标都是1,这两个数的计算会放到map[1]中,形如[47218742,219474827],第一个元素表示一个k-v,第二个元素表示k-v)
  • 创建n个锁:locks = new Object[lockNum];
  • 加锁:synchronized (locks[lockIndex]){ }
  • 锁维度:锁的个数是1~二维数组的行数。

相关内容

热门资讯

linux入门---制作进度条 了解缓冲区 我们首先来看看下面的操作: 我们首先创建了一个文件并在这个文件里面添加了...
C++ 机房预约系统(六):学... 8、 学生模块 8.1 学生子菜单、登录和注销 实现步骤: 在Student.cpp的...
JAVA多线程知识整理 Java多线程基础 线程的创建和启动 继承Thread类来创建并启动 自定义Thread类的子类&#...
【洛谷 P1090】[NOIP... [NOIP2004 提高组] 合并果子 / [USACO06NOV] Fence Repair G ...
国民技术LPUART介绍 低功耗通用异步接收器(LPUART) 简介 低功耗通用异步收发器...
城乡供水一体化平台-助力乡村振... 城乡供水一体化管理系统建设方案 城乡供水一体化管理系统是运用云计算、大数据等信息化手段࿰...
程序的循环结构和random库...   第三个参数就是步长     引入文件时记得指明字符格式,否则读入不了 ...
中国版ChatGPT在哪些方面... 目录 一、中国巨大的市场需求 二、中国企业加速创新 三、中国的人工智能发展 四、企业愿景的推进 五、...
报名开启 | 共赴一场 Flu... 2023 年 1 月 25 日,Flutter Forward 大会在肯尼亚首都内罗毕...
汇编00-MASM 和 Vis... Qt源码解析 索引 汇编逆向--- MASM 和 Visual Studio入门 前提知识ÿ...
【简陋Web应用3】实现人脸比... 文章目录🍉 前情提要🌷 效果演示🥝 实现过程1. u...
前缀和与对数器与二分法 1. 前缀和 假设有一个数组,我们想大量频繁的去访问L到R这个区间的和,...
windows安装JDK步骤 一、 下载JDK安装包 下载地址:https://www.oracle.com/jav...
分治法实现合并排序(归并排序)... 🎊【数据结构与算法】专题正在持续更新中,各种数据结构的创建原理与运用✨...
在linux上安装配置node... 目录前言1,关于nodejs2,配置环境变量3,总结 前言...
Linux学习之端口、网络协议... 端口:设备与外界通讯交流的出口 网络协议:   网络协议是指计算机通信网...
Linux内核进程管理并发同步... 并发同步并发 是指在某一时间段内能够处理多个任务的能力,而 并行 是指同一时间能够处理...
opencv学习-HOG LO... 目录1. HOG(Histogram of Oriented Gradients,方向梯度直方图)1...
EEG微状态的功能意义 导读大脑的瞬时全局功能状态反映在其电场结构上。聚类分析方法一致地提取了四种头表面脑电场结构ÿ...
【Unity 手写PBR】Bu... 写在前面 前期积累: GAMES101作业7提高-实现微表面模型你需要了解的知识 【技...