leftyer/JuiceFS
1
0
Fork 0
mirror of https://gitee.com/juicedata/JuiceFS.git synced 2025-12-06 17:49:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

Hadoop: fix BgTaskUtilTest (#5735)

Browse Source
This commit is contained in:
tangyoupeng
2025-03-06 13:26:47 +08:00
committed by GitHub
parent 0c259cb177
commit e497a241d7
2 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
sdk/java/src/main/java/io/juicefs/utils/BgTaskUtil.java
View File

@@ -15,13 +15,14 @@
*/
package io.juicefs.utils;
import org.apache.hadoop.fs.FileSystem;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
@@ -33,6 +34,12 @@ public class BgTaskUtil {
private static final Map<String, Object> tasks = new HashMap<>(); // volName|taskName -> running
private static final Map<String, Set<Long>> runningInstance = new HashMap<>();
public static void reset() {
bgThreadForName.clear();
tasks.clear();
runningInstance.clear();
}
public static Map<String, ScheduledExecutorService> getBgThreadForName() {
return bgThreadForName;
}

2
sdk/java/src/test/java/io/juicefs/utils/BgTaskUtilTest.java
View File

@@ -13,6 +13,8 @@ public class BgTaskUtilTest extends TestCase {
private static final Logger LOG = LoggerFactory.getLogger(BgTaskUtilTest.class);
public void testBgTask() throws Exception {
BgTaskUtil.reset();
String[] volNames = new String[]{"fs1", "fs2", "fs3"};
String[] taskNames = new String[]{"task1", "task2", "task3"};
int threads = 20;