502647092/TabooLib
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

加了一个大屁眼子

Browse Source
This commit is contained in:
坏黑 2018-06-23 23:31:43 +08:00
parent 3c2d87889e
commit 8564b0bafe
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/me/skymc/taboolib/translateuuid/TranslateUUID.java
View File

@ -118,16 +118,22 @@ public class TranslateUUID {
ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(32); ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(32);
AtomicInteger i = new AtomicInteger(); AtomicInteger i = new AtomicInteger();
AtomicInteger fail = new AtomicInteger();
int size = playerDataFolder.listFiles().length; int size = playerDataFolder.listFiles().length;
TLogger.getGlobalLogger().info("Start importing the local data..."); TLogger.getGlobalLogger().info("Start importing the local data...");
for (File file : playerDataFolder.listFiles()) { for (File file : playerDataFolder.listFiles()) {
if (fail.get() > 10) {
TLogger.getGlobalLogger().info("The number of failures exceeds the threshold! import stopped..");
break;
}
threadPool.submit(() -> { threadPool.submit(() -> {
try { try {
String username = getUsernameInDatFile(file); String username = getUsernameInDatFile(file);
updateUsername(UUID.fromString(file.getName().split("\\.")[0]), username); updateUsername(UUID.fromString(file.getName().split("\\.")[0]), username);
TLogger.getGlobalLogger().info("importing... " + username + "(" + i.getAndIncrement() + "/" + size + ")"); TLogger.getGlobalLogger().info("importing... " + username + "(" + i.getAndIncrement() + "/" + size + ")");
} catch (Exception ignored) { } catch (Exception ignored) {
fail.getAndIncrement();
} }
}); });
} }