ZhouXY108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-04-19 03:01:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix ConcurrencyTester thread size too large, 可能会 java.lang.OutOfMemoryError

Browse Source
This commit is contained in:
duandazhi 2022-06-28 14:56:35 +08:00
parent d6ac2ef4bc
commit e327458eb6
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hutool-core/src/test/java/cn/hutool/core/lang/SimpleCacheTest.java
View File

@ -57,7 +57,7 @@ public class SimpleCacheTest {
@Test @Test
public void getConcurrencyTest(){ public void getConcurrencyTest(){
final SimpleCache<String, String> cache = new SimpleCache<>(); final SimpleCache<String, String> cache = new SimpleCache<>();
final ConcurrencyTester tester = new ConcurrencyTester(9000); final ConcurrencyTester tester = new ConcurrencyTester(2000);
tester.test(()-> cache.get("aaa", ()-> { tester.test(()-> cache.get("aaa", ()-> {
ThreadUtil.sleep(200); ThreadUtil.sleep(200);
return "aaaValue"; return "aaaValue";

2
hutool-core/src/test/java/cn/hutool/core/map/WeakConcurrentMapTest.java
View File

@ -46,7 +46,7 @@ public class WeakConcurrentMapTest {
@Test @Test
public void getConcurrencyTest(){ public void getConcurrencyTest(){
final WeakConcurrentMap<String, String> cache = new WeakConcurrentMap<>(); final WeakConcurrentMap<String, String> cache = new WeakConcurrentMap<>();
final ConcurrencyTester tester = new ConcurrencyTester(9000); final ConcurrencyTester tester = new ConcurrencyTester(2000);
tester.test(()-> cache.computeIfAbsent("aaa" + RandomUtil.randomInt(2), (key)-> "aaaValue")); tester.test(()-> cache.computeIfAbsent("aaa" + RandomUtil.randomInt(2), (key)-> "aaaValue"));
Assert.assertTrue(tester.getInterval() > 0); Assert.assertTrue(tester.getInterval() > 0);