tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-20 12:24:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

test[cache]: LazyCache test

Browse Source
This commit is contained in:
godotg
2024-03-27 17:37:33 +08:00
parent aa3ee29383
commit faace1de6a
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scheduler/src/test/java/com/zfoo/scheduler/util/LazyCacheTest.java
+3 -6
View File
@@ -100,14 +100,15 @@ public class LazyCacheTest {
}
// max size test
@Test
public void multipleThreadTest() {
public void multipleThreadMaxSizeTest() {
int threadNum = Runtime.getRuntime().availableProcessors() + 1;
ExecutorService[] executors = new ExecutorService[threadNum];
for (int i = 0; i < executors.length; i++) {
executors[i] = Executors.newSingleThreadExecutor();
}
var lazyCache = new LazyCache<Integer, String>(1_0000, 10 * TimeUtils.MILLIS_PER_SECOND, 5 * TimeUtils.MILLIS_PER_SECOND, myRemoveCallback);
var lazyCache = new LazyCache<Integer, String>(1_00, 10000000 * TimeUtils.MILLIS_PER_SECOND, 5 * TimeUtils.MILLIS_PER_SECOND, myRemoveCallback);
for (int i = 0; i < executors.length; i++) {
var executor = executors[i];
@@ -119,10 +120,6 @@ public class LazyCacheTest {
for (int j = i1 * 1_0000; j < startIndex + 1_0000; j++) {
lazyCache.put(j, String.valueOf(j));
}
for (int j = 0; j < 10000; j++) {
lazyCache.get(j);
ThreadUtils.sleep(1);
}
}
});
}