Java concurrentHashmap 如何进行分段遍历操作

Java concurrentHashmap 如何进行分段遍历操作

如: concurrentHashmap存了1000条数据;
如何分10次,每次100条进行遍历操作

群里大神提到一种方案:
对长连接进行hash取模,分布在不同的hashmap

我的补充:
如果我想支持50万并发,就一次性的初始化500个hashmap,放到list中
对每个长连接取模,放到对应下标的hashmap中

2个回答

解决方案:two-level hashmap

50万并发?你的意思是50万个线程?这很奇怪的需求,也没有必要,一般来说用threadpool+队列,保持并发在100以内。

u010947098
Rick-Lu netty,长连接
大约一年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
ConcurrenthashMap如何实现并发操作

请教一个问题, 首先在ConcurrenthashMap中预置10万条测试数据 1,我如何使用一个线程对ConcurrenthashMap作操作,先get(key),接着remove(key),直到所有数据remove,记录一下所有时间 2,我如何使用多个线程(3个线程)对ConcurrenthashMap作上面同样的操作,我需要得到两种处理方式所使用的时间 希望能给我简单的demo,谢谢了,小弟线上等待。。。

关于HashMap遍历时删除map中非当前遍历的键值对的问题?

关于HashMap遍历时删除map中非当前遍历的键值对的问题 类似于下面的逻辑,在遍历一个hashmap中元素时,删除非当前遍历到的键值对 按照下面的两种写法,会报错 请问有没有什么遍历方法解决这种逻辑需求 at java.util.HashMap$HashIterator.nextNode(Unknown Source) at java.util.HashMap$EntryIterator.next(Unknown Source) at java.util.HashMap$EntryIterator.next(Unknown Source) > /** * 类似于下面的逻辑,在遍历一个hashmap中元素时,删除非当前遍历到的键值对 *按照下面的两种写法,会报错 *请问有没有什么遍历方法解决这种逻辑需求 *at java.util.HashMap$HashIterator.nextNode(Unknown Source) *at java.util.HashMap$EntryIterator.next(Unknown Source) *at java.util.HashMap$EntryIterator.next(Unknown Source) */ public class Test{ public static void main(String[] args) { HashMap<Integer, Integer> hashMap = new HashMap<>(); for (int i = 0; i < 20; i++) { hashMap.put(i, i); } // 遍历方法1 for (Iterator<Entry<Integer, Integer>> it = hashMap.entrySet().iterator(); it.hasNext();){ Entry<Integer, Integer> next = it.next(); if (hashMap.containsKey(20-next.getKey())) { // 遍历的过程中删除map中的其他key-value hashMap.remove(20-next.getKey()); } } // 遍历方法2 Set<Entry<Integer,Integer>> entrySet = hashMap.entrySet(); for (Entry<Integer, Integer> entry : entrySet) { if (hashMap.containsKey(20-entry.getKey())) { hashMap.remove(20-entry.getKey()); } } } }

关于jdk1.8 ConcurrentHashMap源码 get方法的问题

最近我在看 ConcurrentHashMap源码的时候,看到get()方法(源码如下图所示),其中有一条判断语句 eh < 0 , 因为 ForwardingNode和TreeBin的hash为-1和-2,所以会走这条判断语句,然后执行 return (p = e.find(h, key)) != null ? p.val : null; 如果不满足该条件则说明该节点不是头结点并且hash >= 0,往下执行while()循环。 我的疑问就是,Node、ForwardingNode和TreeBin都实现了find(),那为什么get()还需要做eh < 0的判断呢,直接 return (p = e.find(h, key)) != null ? p.val : null; 不就好了,根据e的类型执行各自的find()?,该判断和while()循环存在的道理是什么呢? ![图片说明](https://img-ask.csdn.net/upload/201708/31/1504149373_380650.png)

求高手帮我解惑一下concurrentHashMap的问题

import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; public class ConcurrentHashMapTest { private static final ConcurrentMap<String, String> factory = new ConcurrentHashMap<String, String>(); public static void main(String[] args) { for(int i=0;i<10;i++){ new Thread(i+""){ public void run(){ String tf = factory.get("wang"); if (tf == null) { try { Thread.sleep((int)(Math.random()*1000)); factory.put("wang", this.getName()); Thread.sleep((int)(Math.random()*1000)); } catch (Throwable e) { e.printStackTrace(); } } System.out.println(this.getName()+"_"+factory.get("wang")); } }.start(); } } } 上面这段代码中concurrentHashMap好像没起到作用,有高手帮忙解惑下吗

ConcurrentHashMap在JDK8中是不是没有全表加锁的情况了?

在1.7版本size()方法试3次后会出现全表加锁统计的情况,1.8里改用CAS计算了是不是就没有全表加锁的情况了?还是我看漏了...

concurrentHashMap在扩容进行数据迁移时,每个数组节点下面的元素的hash值为啥不相等?

concurrentHashMap在扩容进行数据迁移时,每个数组节点下面的元素的hash值为啥不相等?所以才会有高位元素和低位元素之分。

concurrentHashMap是线程安全且强一致性的吗?

看了文档,但是不是很明白,这个类可以在不阻塞线程的情况下提供线程安全的并发写,但是他没有对读进行同步,那么,假如读和写发生在同一个元素的时候,怎么办?这时候不做同步,那么数据肯定是脏的啊?还是我理解有错,大家都怎么使用这个类咧

ConcurrentHashMap中内部类Segment中的count和threshold

![图片说明](https://img-ask.csdn.net/upload/201910/14/1571062410_953240.jpg) 当Segment初始化的时候闯将HashEntry数组时,大小为cap,threshold也为扩容系数*数组的大小,我的理解是根据数组实例化的个数是否大于threshold来判断是否扩容的。而在Segment类中的put方法中,明显的是判断tab中元素的个数(包括链表上的元素)和threshold比较的呢?,求解答![图片说明](https://img-ask.csdn.net/upload/201910/14/1571062481_859709.jpg)

多线程环境下使用线程安全的ConcurrentHashMap代码有何问题

![图片说明](https://img-ask.csdn.net/upload/201705/23/1495507632_656868.jpg)

spring 里面的 bean 池为啥要用 ConcurrentHashMap

在 spring getbean() 的时候,如果是 singleton 的话, bean实例化后 会保存在 一个 ConcurrentHashMap 中, 我的问题是为什么要用 ConcurrentHashMap? 我觉得 HashMap 也可以啊。目前我自己要实现一个 简易的 bean 池, 里面的 bean 不要求线程安全,那么是不是可以直接用 HashMap 了? 期待牛人的解答

【java】jmap -histo pid 输出的[B 占用很高,请问问题会在哪里?

公司目前的程序是解析excel表格内容,使用到了poi sax方式解析,但是在监控的过程中发现堆内存B的占用非常高,使用mat工具也告诉B可能存在内存泄漏问题。 代码中那些操作会导致这个问题呢?代码中只使用了一个inputstream来保存文件,而且使用后也关闭了 是在找不到,但是B占了相当多的空间 b就是byte数据(下面这个不是我的图,是我找的一个例图,就是B那个地方,我这里显示的是占用最高的,我不知道我的程序哪里写错了会导致这种情况) ``` num #instances #bytes class name ---------------------------------------------- 1: 1169837 131659368 [C 2: 25945 38337824 [I 3: 31548 29407968 [B 4: 1164546 27949104 java.lang.String 6: 91313 12829072 <constMethodKlass> 7: 12395 12404880 [S 8: 91313 11700288 <methodKlass> 9: 7525 9303112 <constantPoolKlass> 10: 7525 5606808 <instanceKlassKlass> 11: 6043 5028288 <constantPoolCacheKlass> 12: 10048 2007888 [Ljava.lang.Object; 14: 3507 1707048 <methodDataKlass> 15: 8132 980616 java.lang.Class 16: 26854 859328 java.util.HashMap$Entry 17: 12368 699296 [[I 18: 14135 452320 java.util.concurrent.ConcurrentHashMap$HashEntry 19: 20883 334128 java.lang.Object 20: 590 316240 <objArrayKlassKlass> 21: 1757 305904 [Ljava.util.HashMap$Entry; 22: 2809 224720 net.sf.ehcache.Element 23: 1992 223104 java.net.SocksSocketImpl 24: 2668 213440 java.lang.reflect.Method 26: 5932 183928 [Ljava.lang.String; 27: 7588 182112 java.util.concurrent.ConcurrentSkipListMap$Node 28: 7317 175608 java.lang.Long 29: 5303 169696 java.util.Hashtable$Entry 30: 6778 162672 java.util.ArrayList 31: 3931 157240 java.lang.ref.SoftReference 32: 2972 118880 java.util.LinkedHashMap$Entry 33: 1565 112680 org.apache.commons.pool2.impl.DefaultPooledObject 34: 2817 112680 net.sf.ehcache.store.chm.SelectableConcurrentHashMap$HashEntry 35: 2243 107664 java.util.HashMap 36: 2592 103680 java.util.TreeMap$Entry 37: 3214 102848 java.lang.ref.WeakReference 38: 1565 100160 redis.clients.jedis.Client 39: 4155 99720 java.util.LinkedList$Node 40: 1986 95328 java.net.SocketInputStream 41: 414 92952 [Ljava.util.concurrent.ConcurrentHashMap$HashEntry; 42: 2275 91000 java.lang.ref.Finalizer 43: 1161 83592 java.lang.reflect.Constructor 44: 757 78728 java.io.ObjectStreamClass 45: 1587 76176 java.net.SocketOutputStream 46: 1189 66584 java.beans.MethodDescriptor 47: 2770 66480 org.apache.commons.pool2.impl.LinkedBlockingDeque$Node 48: 388 66368 [Ljava.util.Hashtable$Entry; 49: 1989 63648 java.net.Socket 50: 749 53928 java.lang.reflect.Field ... ... 2947: 1 16 sun.misc.Launcher 2948: 1 16 org.codehaus.jackson.map.ser.std.DateSerializer 2949: 1 16 org.apache.phoenix.schema.types.PDataType$2 2950: 1 16 org.springframework.data.redis.connection.convert.StringToRedisClientInfoConverter Total 3090439 316004152 ```

从ConcurrentHashMap中取数据时,遇到很怪异的问题

这是我的一段代码: public UserConnection getUserConnectionByToken(Token token) { // TODO Auto-generated method stub for (Iterator<Token> iter = (Iterator<Token>) TransactionManagerImpl.userConnections .keySet().iterator(); iter.hasNext();) { Token token1 = iter.next(); if(token1.equals(token)){ return userConnections.get(token1); } } return (UserConnection)userConnections.get(token); } 其中userConnections是一个ConcurrentHashMap,里面的key是Token对象,value是UserConnection 对象,这是webservice服务端的一个方法,token是在客户端传过来的,都实现了序列化,但是在服务端处理的时候,直接 userConnections.get(token)却取不出来,但是通过迭代判断if(token1.equals(token)){return userConnections.get(token1);}却能取出来,这是怎么回事儿呢,哪位帮解释一下?

ConcurrentHashMap获取Segment数组某下标元素时为什么使用Unsafe的getObject而不是直接使用数组[i]呢?

JDK1.7的ConcurrentHashMap中的put方法,在根据key计算得出 Segment数组下标之后,使用了UNSAFE.getObject(segments, (j << SSHIFT) + SBASE),根据数组对象和偏移量来获取数组下标的元素,那么为什么 不直接使用segments[j]这种方式呢? 难道跟并发安全或者说数组[i]这种方式编译后也是使用类似Unsafe这种根据 根据对象起始地址+偏移量来定位获取元素的所以可以省略一些编译解析的消耗呢?

新手关于使用java集合造成的java.lang.StackOverflowError

如图的题目,![图片说明](https://img-ask.csdn.net/upload/201602/27/1456582254_892569.png) 据此,我写了三个类,第一个Student类,代码: ``` package com.wms.StudentManager2; import java.util.List; public class Student { private String name; private int age; private List crList; public List crList() { return crList; } public void setName(String name) { this.name = name; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public List getList() { return crList; } public void setList(List crList) { this.crList = crList; } public Student(String name, int age) { super(); this.name = name; this.age = age; } public Student() {} @Override public String toString() { if(crList==null){ return "Student [name=" + name + ", age=" + age + "该生从未选课"; } return "Student [name=" + name + ", age=" + age + ", course=" + crList + "]"; } } ``` 第二个Course类,代码: ``` package com.wms.StudentManager2; import java.util.List; public class Course { private String name; private int score; private List stuList; public String getName() { return name; } public void setName(String name) { this.name = name; } public int getScore() { return score; } public void setScore(int score) { this.score = score; } public List getList() { return stuList; } public void setList(List stuList) { this.stuList = stuList; } public Course(String name, int score,List stuList) { super(); this.name = name; this.score = score; this.stuList = stuList; } public Course() {} @Override public String toString() { return "Course [name=" + name + ", score=" + score + ", student=" + stuList + "]"; } } ``` 第三个Manager类,代码: ``` package com.wms.StudentManager2; import java.util.ArrayList; import java.util.List; public class Manager { public static void main(String[] args) { Student s1 = new Student("张小三", 20); Student s2 = new Student("李小思", 19); Student s3 = new Student("王五", 18); Student s4 = new Student("赵晓丽", 19); Student s5 = new Student("黎明", 20); List<Student> stuList1 = new ArrayList<>(); List<Student> stuList2 = new ArrayList<>(); List<Student> stuList3 = new ArrayList<>(); stuList1.add(s1); stuList1.add(s2); stuList1.add(s3); stuList1.add(s4); stuList2.add(s1); stuList3.add(s1); Course c1 = new Course("高等数学", 5, stuList1); Course c2 = new Course("线性代数", 3, stuList2); Course c3 = new Course("离散数学", 4, stuList3); List<Course> crList1 = new ArrayList(); List<Course> crList2 = new ArrayList(); List<Course> crList3 = new ArrayList(); List<Course> crList4 = new ArrayList(); crList1.add(c1); crList1.add(c2); crList1.add(c3); crList2.add(c1); crList3.add(c1); crList4.add(c1); s1.setList(crList1); s2.setList(crList2); s3.setList(crList3); s4.setList(crList4); System.out.println(c1); } } ``` 如果我不给student setCourseList就可以正常,但是一旦set之后就会报java.lang.StackOverflowError, at java.lang.StringBuilder.<init>(Unknown Source) at com.wms.StudentManager2.Student.toString(Student.java:40) at java.lang.String.valueOf(Unknown Source)等等错误。实在不知道问题出在哪里,希望大家帮忙看下。

mybatis nullpointerexception

## console ``` org.apache.ibatis.exceptions.PersistenceException: ### Error querying database. Cause: java.lang.NullPointerException ### The error may exist in sqlMap/User.xml ### The error may involve test.findAllUser ### The error occurred while executing a query ### Cause: java.lang.NullPointerExceptionorg.apache.ibatis.exceptions.PersistenceException: ### Error querying database. Cause: java.lang.NullPointerException ### The error may exist in sqlMap/User.xml ### The error may involve test.findAllUser ### The error occurred while executing a query ### Cause: java.lang.NullPointerException at org.apache.ibatis.exceptions.ExceptionFactory.wrapException(ExceptionFactory.java:30) at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:149) at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:140) at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:135) at cn.mybatis.test.Main1.findAllUser(Main1.java:30) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57) at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) at org.junit.runners.ParentRunner.run(ParentRunner.java:363) at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86) at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:678) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192) Caused by: java.lang.NullPointerException at java.util.concurrent.ConcurrentHashMap.get(ConcurrentHashMap.java:936) at java.util.concurrent.ConcurrentHashMap.containsKey(ConcurrentHashMap.java:964) at org.apache.ibatis.datasource.unpooled.UnpooledDataSource.initializeDriver(UnpooledDataSource.java:207) at org.apache.ibatis.datasource.unpooled.UnpooledDataSource.doGetConnection(UnpooledDataSource.java:200) at org.apache.ibatis.datasource.unpooled.UnpooledDataSource.doGetConnection(UnpooledDataSource.java:196) at org.apache.ibatis.datasource.unpooled.UnpooledDataSource.getConnection(UnpooledDataSource.java:93) at org.apache.ibatis.datasource.pooled.PooledDataSource.popConnection(PooledDataSource.java:403) at org.apache.ibatis.datasource.pooled.PooledDataSource.getConnection(PooledDataSource.java:89) at org.apache.ibatis.transaction.jdbc.JdbcTransaction.openConnection(JdbcTransaction.java:138) at org.apache.ibatis.transaction.jdbc.JdbcTransaction.getConnection(JdbcTransaction.java:60) at org.apache.ibatis.executor.BaseExecutor.getConnection(BaseExecutor.java:336) at org.apache.ibatis.executor.SimpleExecutor.prepareStatement(SimpleExecutor.java:85) at org.apache.ibatis.executor.SimpleExecutor.doQuery(SimpleExecutor.java:62) at org.apache.ibatis.executor.BaseExecutor.queryFromDatabase(BaseExecutor.java:324) at org.apache.ibatis.executor.BaseExecutor.query(BaseExecutor.java:156) at org.apache.ibatis.executor.CachingExecutor.query(CachingExecutor.java:109) at org.apache.ibatis.executor.CachingExecutor.query(CachingExecutor.java:83) at org.apache.ibatis.session.defaults.DefaultSqlSession.selectList(DefaultSqlSession.java:147) ... 26 more ``` ## User.xml ``` <?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="test"> <select id="findAllUser" resultType="cn.mybatis.domain.User"> select * from user </select> </mapper> ``` ## Main1.java ``` public class Main1 { @Test public void findAllUser() throws IOException{ String resource = "sqlMapConfig.xml"; InputStream inputStream = org.apache.ibatis.io.Resources.getResourceAsStream(resource); SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(inputStream); SqlSession session = sessionFactory.openSession(); try { java.util.List<User> list = session.selectList("test.findAllUser"); System.out.println(list); } catch (Exception e) { e.printStackTrace(); System.out.println(e); }finally{ session.close(); } } } ``` ## sqlMapConfig.xml ``` <?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <!-- mybatis初始化环境配置,可以有多个环境 --> <environments default="development"> <!-- 配置当前的运行环境 --> <environment id="development"> <!-- 事务,由mybatis管理 --> <transactionManager type="JDBC"/> <!-- jdbc数据源,mybatis管理 --> <dataSource type="POOLED"> <!-- <property name="driver" value="com.mysql.jdbc.driver"/> --> <property name="url" value="jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf-8;serverTimezone=GMT%2B8"/> <property name="username" value="root"/> <property name="password" value="{Zzhuxiaotianswzs0$}"/> </dataSource> </environment> </environments> <mappers> <mapper resource="sqlMap/User.xml"/> </mappers> </configuration> ``` ## User.java ``` package cn.mybatis.domain; public class User { private Integer id; private String username; private String birthday; private String sex; private String address; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getBirthday() { return birthday; } public void setBirthday(String birthday) { this.birthday = birthday; } public String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } } ```

在多线程情况下,不使用同步,对同一个MAP的并发读写问题

假设有以下场景: 某一个业务要求,定时的从数据库中取出一批数据放入一个hashmap中。 有多个线程对这个MAP进行读操作。 每过一段时间(如3分钟),都会对这个MAP进行修改(put or remove) 该场景对数据的一致性没有非常严格的要求。 如何能够在不使用同步的情况下,对这个MAP进行安全的操作呢?(例如不用concurrentHashMap,或Collections.synchronizedMap) 我的想法是,每次在需要修改MAP的时候,可以创建一个旧MAP的副本,对副本进行修改后,再替换原先的MAP 例如: Map newMap = oldMap.clone(); //或者用new HashMap().putall(oldMap)来创造副本 newMap.put / remove ..... //修改map oldMap = newMap; //替换上去 这样就不会因为对同一个map的并发读写而导致快速迭代失败。有没有大神看看这样有什么潜在的问题,比如GC。。请不吝赐教>_< ( jdk 1.6 api hashMap 在迭代器创建之后,如果从结构上对映射进行修改,除非通过迭代器本身的 remove 方法,其他任何时间任何方式的修改,迭代器都将抛出 ConcurrentModificationException。因此,面对并发的修改,迭代器很快就会完全失败,而不冒在将来不确定的时间发生任意不确定行为的风险。 )

HttpSessionBindingListener ConcurrentHashMap

在springmvc项目中实现了HttpSessionBindingListener 并且在valueBound中将HttpSession加入到了public static final Map<String, Object> sessionMap = new ConcurrentHashMap<String, Object>(); 然后在controller中得到了sessionMap 并通过key获取到了某个HttpSession 不知道为什么一旦调用session.invalidate();就会报java.util.ConcurrentModificationException的错误: java.util.ConcurrentModificationException at java.util.ArrayList$Itr.checkForComodification(ArrayList.java:859) at java.util.ArrayList$Itr.next(ArrayList.java:831) at com.sihan.gmrcsubs.action.auth.SysUserAction.deleteUser(SysUserAction.java:209) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at org.springframework.web.method.support.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:219) at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:132) at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:745) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:686) at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:80) at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:925) at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:856) at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:920) at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:827) at javax.servlet.http.HttpServlet.service(HttpServlet.java:646) at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:801) at javax.servlet.http.HttpServlet.service(HttpServlet.java:727) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:303) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) at com.alibaba.druid.support.http.WebStatFilter.doFilter(WebStatFilter.java:123) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:88) at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:241) at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:208) at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:220) at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:122) at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:501) at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171) at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:103) at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:950) at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:116) at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:408) at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1070) at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:611) at org.apache.tomcat.util.net.AprEndpoint$SocketProcessor.doRun(AprEndpoint.java:2440) at org.apache.tomcat.util.net.AprEndpoint$SocketProcessor.run(AprEndpoint.java:2429) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(Thread.java:745) 但是并未调用map.remmove()方法,求大神帮助 另外若通过controller方法上的request获取httpsession并调用invalidate方法,在触发HttpSessionBindingListener 的valueUnbound方法时我进行了map.remove() 却没有保存结果也是正确的

EHCache报出java.lang.IllegalMonitorStateException异常

我写的代码如下所示,其中EHCacheService.putIn是封装了EHCache的put函数,key=1,一直key++。 import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class EHCacheTestCallable implements Callable { @Override public Object call() throws Exception { //for (int i = 0; i < thresd; i++) { for (int i = 0; ; i++) { EHCacheService.putIn("aba"); } } public static void main(String[] args) { EHCacheTestCallable psc = new EHCacheTestCallable(); ExecutorService es = Executors.newFixedThreadPool(1); @SuppressWarnings({ "unchecked", "unused" }) Future recvHandler = es.submit(psc); } } 另外ehcache.xml中配置为: <cache name="sampleCache1" maxElementsInMemory="10000" eternal="false" timeToIdleSeconds="300" timeToLiveSeconds="600" overflowToDisk="true" /> 存储的内容为一个字符串“aba”,存到2138639个的时候出现异常。 异常结果显示为: Exception in thread "pool-1-thread-1" java.lang.IllegalMonitorStateException at java.util.concurrent.locks.ReentrantLock$Sync.tryRelease(Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer.release(Unknown Source) at java.util.concurrent.locks.ReentrantLock.unlock(Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.lang.Thread.run(Unknown Source)

concurrentHashMap 构造方法

int c = initialCapacity / ssize; if (c * ssize < initialCapacity) ++c; int cap = MIN_SEGMENT_TABLE_CAPACITY; while (cap < c) cap <<= 1; 不太懂这一段是干嘛的,不清楚++c什么情况下会发生,还有cap就是hashEntry的size吗?

在中国程序员是青春饭吗?

今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...

程序员请照顾好自己,周末病魔差点一套带走我。

程序员在一个周末的时间,得了重病,差点当场去世,还好及时挽救回来了。

Java基础知识面试题(2020最新版)

文章目录Java概述何为编程什么是Javajdk1.5之后的三大版本JVM、JRE和JDK的关系什么是跨平台性?原理是什么Java语言有哪些特点什么是字节码?采用字节码的最大好处是什么什么是Java程序的主类?应用程序和小程序的主类有何不同?Java应用程序与小程序之间有那些差别?Java和C++的区别Oracle JDK 和 OpenJDK 的对比基础语法数据类型Java有哪些数据类型switc...

技术大佬:我去,你写的 switch 语句也太老土了吧

昨天早上通过远程的方式 review 了两名新来同事的代码,大部分代码都写得很漂亮,严谨的同时注释也很到位,这令我非常满意。但当我看到他们当中有一个人写的 switch 语句时,还是忍不住破口大骂:“我擦,小王,你丫写的 switch 语句也太老土了吧!” 来看看小王写的代码吧,看完不要骂我装逼啊。 private static String createPlayer(PlayerTypes p...

和黑客斗争的 6 天!

互联网公司工作,很难避免不和黑客们打交道,我呆过的两家互联网公司,几乎每月每天每分钟都有黑客在公司网站上扫描。有的是寻找 Sql 注入的缺口,有的是寻找线上服务器可能存在的漏洞,大部分都...

Intellij IDEA 实用插件安利

1. 前言从2020 年 JVM 生态报告解读 可以看出Intellij IDEA 目前已经稳坐 Java IDE 头把交椅。而且统计得出付费用户已经超过了八成(国外统计)。IDEA 的...

女程序员,为什么比男程序员少???

昨天看到一档综艺节目,讨论了两个话题:(1)中国学生的数学成绩,平均下来看,会比国外好?为什么?(2)男生的数学成绩,平均下来看,会比女生好?为什么?同时,我又联想到了一个技术圈经常讨...

总结了 150 余个神奇网站,你不来瞅瞅吗?

原博客再更新,可能就没了,之后将持续更新本篇博客。

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

MySQL数据库面试题(2020最新版)

文章目录数据库基础知识为什么要使用数据库什么是SQL?什么是MySQL?数据库三大范式是什么mysql有关权限的表都有哪几个MySQL的binlog有有几种录入格式?分别有什么区别?数据类型mysql有哪些数据类型引擎MySQL存储引擎MyISAM与InnoDB区别MyISAM索引与InnoDB索引的区别?InnoDB引擎的4大特性存储引擎选择索引什么是索引?索引有哪些优缺点?索引使用场景(重点)...

如果你是老板,你会不会踢了这样的员工?

有个好朋友ZS,是技术总监,昨天问我:“有一个老下属,跟了我很多年,做事勤勤恳恳,主动性也很好。但随着公司的发展,他的进步速度,跟不上团队的步伐了,有点...

我入职阿里后,才知道原来简历这么写

私下里,有不少读者问我:“二哥,如何才能写出一份专业的技术简历呢?我总感觉自己写的简历太烂了,所以投了无数份,都石沉大海了。”说实话,我自己好多年没有写过简历了,但我认识的一个同行,他在阿里,给我说了一些他当年写简历的方法论,我感觉太牛逼了,实在是忍不住,就分享了出来,希望能够帮助到你。 01、简历的本质 作为简历的撰写者,你必须要搞清楚一点,简历的本质是什么,它就是为了来销售你的价值主张的。往深...

魂迁光刻,梦绕芯片,中芯国际终获ASML大型光刻机

据羊城晚报报道,近日中芯国际从荷兰进口的一台大型光刻机,顺利通过深圳出口加工区场站两道闸口进入厂区,中芯国际发表公告称该光刻机并非此前盛传的EUV光刻机,主要用于企业复工复产后的生产线扩容。 我们知道EUV主要用于7nm及以下制程的芯片制造,光刻机作为集成电路制造中最关键的设备,对芯片制作工艺有着决定性的影响,被誉为“超精密制造技术皇冠上的明珠”,根据之前中芯国际的公报,目...

优雅的替换if-else语句

场景 日常开发,if-else语句写的不少吧??当逻辑分支非常多的时候,if-else套了一层又一层,虽然业务功能倒是实现了,但是看起来是真的很不优雅,尤其是对于我这种有强迫症的程序"猿",看到这么多if-else,脑袋瓜子就嗡嗡的,总想着解锁新姿势:干掉过多的if-else!!!本文将介绍三板斧手段: 优先判断条件,条件不满足的,逻辑及时中断返回; 采用策略模式+工厂模式; 结合注解,锦...

离职半年了,老东家又发 offer,回不回?

有小伙伴问松哥这个问题,他在上海某公司,在离职了几个月后,前公司的领导联系到他,希望他能够返聘回去,他很纠结要不要回去? 俗话说好马不吃回头草,但是这个小伙伴既然感到纠结了,我觉得至少说明了两个问题:1.曾经的公司还不错;2.现在的日子也不是很如意。否则应该就不会纠结了。 老实说,松哥之前也有过类似的经历,今天就来和小伙伴们聊聊回头草到底吃不吃。 首先一个基本观点,就是离职了也没必要和老东家弄的苦...

2020阿里全球数学大赛:3万名高手、4道题、2天2夜未交卷

阿里巴巴全球数学竞赛( Alibaba Global Mathematics Competition)由马云发起,由中国科学技术协会、阿里巴巴基金会、阿里巴巴达摩院共同举办。大赛不设报名门槛,全世界爱好数学的人都可参与,不论是否出身数学专业、是否投身数学研究。 2020年阿里巴巴达摩院邀请北京大学、剑桥大学、浙江大学等高校的顶尖数学教师组建了出题组。中科院院士、美国艺术与科学院院士、北京国际数学...

为什么你不想学习?只想玩?人是如何一步一步废掉的

不知道是不是只有我这样子,还是你们也有过类似的经历。 上学的时候总有很多光辉历史,学年名列前茅,或者单科目大佬,但是虽然慢慢地长大了,你开始懈怠了,开始废掉了。。。 什么?你说不知道具体的情况是怎么样的? 我来告诉你: 你常常潜意识里或者心理觉得,自己真正的生活或者奋斗还没有开始。总是幻想着自己还拥有大把时间,还有无限的可能,自己还能逆风翻盘,只不是自己还没开始罢了,自己以后肯定会变得特别厉害...

男生更看重女生的身材脸蛋,还是思想?

往往,我们看不进去大段大段的逻辑。深刻的哲理,往往短而精悍,一阵见血。问:产品经理挺漂亮的,有点心动,但不知道合不合得来。男生更看重女生的身材脸蛋,还是...

为什么程序员做外包会被瞧不起?

二哥,有个事想询问下您的意见,您觉得应届生值得去外包吗?公司虽然挺大的,中xx,但待遇感觉挺低,马上要报到,挺纠结的。

当HR压你价,说你只值7K,你该怎么回答?

当HR压你价,说你只值7K时,你可以流畅地回答,记住,是流畅,不能犹豫。 礼貌地说:“7K是吗?了解了。嗯~其实我对贵司的面试官印象很好。只不过,现在我的手头上已经有一份11K的offer。来面试,主要也是自己对贵司挺有兴趣的,所以过来看看……”(未完) 这段话主要是陪HR互诈的同时,从公司兴趣,公司职员印象上,都给予对方正面的肯定,既能提升HR的好感度,又能让谈判气氛融洽,为后面的发挥留足空间。...

面试:第十六章:Java中级开发

HashMap底层实现原理,红黑树,B+树,B树的结构原理 Spring的AOP和IOC是什么?它们常见的使用场景有哪些?Spring事务,事务的属性,传播行为,数据库隔离级别 Spring和SpringMVC,MyBatis以及SpringBoot的注解分别有哪些?SpringMVC的工作原理,SpringBoot框架的优点,MyBatis框架的优点 SpringCould组件有哪些,他们...

面试阿里p7,被按在地上摩擦,鬼知道我经历了什么?

面试阿里p7被问到的问题(当时我只知道第一个):@Conditional是做什么的?@Conditional多个条件是什么逻辑关系?条件判断在什么时候执...

Python爬虫,高清美图我全都要(彼岸桌面壁纸)

爬取彼岸桌面网站较为简单,用到了requests、lxml、Beautiful Soup4

差点跪了...

最近微信又搞出了一个大利器,甚至都上了热搜,当然消息最敏捷的自媒体人,纷纷都开通了自己的视频号。01 视频号是什么呢?视频号是微信体系内的短视频,它不同...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

Vue回炉重造之router路由(更新中)

你好,我是Vam的金豆之路,可以叫我豆哥。2019年年度博客之星、技术领域博客专家。主要领域:前端开发。我的微信是 maomin9761,有什么疑问可以加我哦,自己创建了一个微信技术交流群,可以加我邀请你一起交流学习。最后自己也创建了一个微信公众号,里面的文章是我自己精挑细选的文章,主要介绍各种IT新技术。欢迎关注哦,微信搜索:臻美IT,等你来。 欢迎阅读本博文,本博文主要讲述【】,文字通...

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

Java岗开发3年,公司临时抽查算法,离职后这几题我记一辈子

前几天我们公司做了一件蠢事,非常非常愚蠢的事情。我原以为从学校出来之后,除了找工作有测试外,不会有任何与考试有关的事儿。 但是,天有不测风云,公司技术总监、人事总监两位大佬突然降临到我们事业线,叫上我老大,给我们组织了一场别开生面的“考试”。 那是一个风和日丽的下午,我翘着二郎腿,左手端着一杯卡布奇诺,右手抓着我的罗技鼠标,滚动着轮轴,穿梭在头条热点之间。 “淡黄的长裙~蓬松的头发...

大胆预测下未来5年的Web开发

在2019年的ReactiveConf 上,《Elm in Action》的作者Richard Feldman对未来5年Web开发的发展做了预测,很有意思,分享给大家。如果你有机会从头...

立即提问
相关内容推荐