Mirror von
https://github.com/ViaVersion/ViaVersion.git
synchronisiert 2024-12-28 09:00:09 +01:00
Tidy up concurrent mapping loading
Dieser Commit ist enthalten in:
Ursprung
bdeb5acae9
Commit
9b4d50b214
@ -1,5 +1,6 @@
|
|||||||
package us.myles.ViaVersion.api.protocol;
|
package us.myles.ViaVersion.api.protocol;
|
||||||
|
|
||||||
|
import com.google.common.base.Preconditions;
|
||||||
import com.google.common.collect.Lists;
|
import com.google.common.collect.Lists;
|
||||||
import com.google.common.collect.Range;
|
import com.google.common.collect.Range;
|
||||||
import com.google.common.util.concurrent.ThreadFactoryBuilder;
|
import com.google.common.util.concurrent.ThreadFactoryBuilder;
|
||||||
@ -57,6 +58,9 @@ import java.util.concurrent.SynchronousQueue;
|
|||||||
import java.util.concurrent.ThreadFactory;
|
import java.util.concurrent.ThreadFactory;
|
||||||
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.ThreadPoolExecutor;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
import java.util.concurrent.locks.ReadWriteLock;
|
||||||
|
import java.util.concurrent.locks.ReentrantReadWriteLock;
|
||||||
|
import java.util.function.Function;
|
||||||
|
|
||||||
public class ProtocolRegistry {
|
public class ProtocolRegistry {
|
||||||
public static final Protocol BASE_PROTOCOL = new BaseProtocol();
|
public static final Protocol BASE_PROTOCOL = new BaseProtocol();
|
||||||
@ -70,7 +74,7 @@ public class ProtocolRegistry {
|
|||||||
private static final List<Pair<Range<Integer>, Protocol>> baseProtocols = Lists.newCopyOnWriteArrayList();
|
private static final List<Pair<Range<Integer>, Protocol>> baseProtocols = Lists.newCopyOnWriteArrayList();
|
||||||
private static final List<Protocol> registerList = new ArrayList<>();
|
private static final List<Protocol> registerList = new ArrayList<>();
|
||||||
|
|
||||||
private static final Object MAPPING_LOADER_LOCK = new Object();
|
private static final ReadWriteLock MAPPING_LOADER_LOCK = new ReentrantReadWriteLock();
|
||||||
private static Map<Class<? extends Protocol>, CompletableFuture<Void>> mappingLoaderFutures = new HashMap<>();
|
private static Map<Class<? extends Protocol>, CompletableFuture<Void>> mappingLoaderFutures = new HashMap<>();
|
||||||
private static ThreadPoolExecutor mappingLoaderExecutor;
|
private static ThreadPoolExecutor mappingLoaderExecutor;
|
||||||
private static boolean mappingsLoaded;
|
private static boolean mappingsLoaded;
|
||||||
@ -353,9 +357,10 @@ public class ProtocolRegistry {
|
|||||||
if (mappingsLoaded) return;
|
if (mappingsLoaded) return;
|
||||||
|
|
||||||
CompletableFuture<Void> future = getMappingLoaderFuture(protocolClass);
|
CompletableFuture<Void> future = getMappingLoaderFuture(protocolClass);
|
||||||
if (future == null) return;
|
if (future != null) {
|
||||||
|
// Wait for completion
|
||||||
future.get();
|
future.get();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -364,7 +369,8 @@ public class ProtocolRegistry {
|
|||||||
* @return true if the executor has now been shut down
|
* @return true if the executor has now been shut down
|
||||||
*/
|
*/
|
||||||
public static boolean checkForMappingCompletion() {
|
public static boolean checkForMappingCompletion() {
|
||||||
synchronized (MAPPING_LOADER_LOCK) {
|
MAPPING_LOADER_LOCK.readLock().lock();
|
||||||
|
try {
|
||||||
if (mappingsLoaded) return false;
|
if (mappingsLoaded) return false;
|
||||||
|
|
||||||
for (CompletableFuture<Void> future : mappingLoaderFutures.values()) {
|
for (CompletableFuture<Void> future : mappingLoaderFutures.values()) {
|
||||||
@ -376,10 +382,68 @@ public class ProtocolRegistry {
|
|||||||
|
|
||||||
shutdownLoaderExecutor();
|
shutdownLoaderExecutor();
|
||||||
return true;
|
return true;
|
||||||
|
} finally {
|
||||||
|
MAPPING_LOADER_LOCK.readLock().unlock();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Executes the given runnable asynchronously, adding a {@link CompletableFuture}
|
||||||
|
* to the list of data to load bound to their protocols.
|
||||||
|
*
|
||||||
|
* @param protocolClass protocol class
|
||||||
|
* @param runnable runnable to be executed asynchronously
|
||||||
|
*/
|
||||||
|
public static void addMappingLoaderFuture(Class<? extends Protocol> protocolClass, Runnable runnable) {
|
||||||
|
CompletableFuture<Void> future = CompletableFuture.runAsync(runnable, mappingLoaderExecutor).exceptionally(mappingLoaderThrowable(protocolClass));
|
||||||
|
|
||||||
|
MAPPING_LOADER_LOCK.writeLock().lock();
|
||||||
|
try {
|
||||||
|
mappingLoaderFutures.put(protocolClass, future);
|
||||||
|
} finally {
|
||||||
|
MAPPING_LOADER_LOCK.writeLock().unlock();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Executes the given runnable asynchronously after the other protocol has finished its data loading,
|
||||||
|
* adding a {@link CompletableFuture} to the list of data to load bound to their protocols.
|
||||||
|
*
|
||||||
|
* @param protocolClass protocol class
|
||||||
|
* @param runnable runnable to be executed asynchronously
|
||||||
|
*/
|
||||||
|
public static void addMappingLoaderFuture(Class<? extends Protocol> protocolClass, Class<? extends Protocol> dependsOn, Runnable runnable) {
|
||||||
|
CompletableFuture<Void> future = getMappingLoaderFuture(dependsOn)
|
||||||
|
.whenCompleteAsync((v, throwable) -> runnable.run(), mappingLoaderExecutor).exceptionally(mappingLoaderThrowable(protocolClass));
|
||||||
|
|
||||||
|
MAPPING_LOADER_LOCK.writeLock().lock();
|
||||||
|
try {
|
||||||
|
mappingLoaderFutures.put(protocolClass, future);
|
||||||
|
} finally {
|
||||||
|
MAPPING_LOADER_LOCK.writeLock().unlock();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns the data loading future bound to the protocol, or null if all loading is complete.
|
||||||
|
* The future may or may not have already been completed.
|
||||||
|
*
|
||||||
|
* @param protocolClass protocol class
|
||||||
|
* @return data loading future bound to the protocol, or null if all loading is complete
|
||||||
|
*/
|
||||||
|
@Nullable
|
||||||
|
public static CompletableFuture<Void> getMappingLoaderFuture(Class<? extends Protocol> protocolClass) {
|
||||||
|
MAPPING_LOADER_LOCK.readLock().lock();
|
||||||
|
try {
|
||||||
|
return mappingsLoaded ? null : mappingLoaderFutures.get(protocolClass);
|
||||||
|
} finally {
|
||||||
|
MAPPING_LOADER_LOCK.readLock().unlock();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void shutdownLoaderExecutor() {
|
private static void shutdownLoaderExecutor() {
|
||||||
|
Preconditions.checkArgument(!mappingsLoaded);
|
||||||
|
|
||||||
Via.getPlatform().getLogger().info("Finished mapping loading, shutting down loader executor!");
|
Via.getPlatform().getLogger().info("Finished mapping loading, shutting down loader executor!");
|
||||||
mappingsLoaded = true;
|
mappingsLoaded = true;
|
||||||
mappingLoaderExecutor.shutdown();
|
mappingLoaderExecutor.shutdown();
|
||||||
@ -391,34 +455,11 @@ public class ProtocolRegistry {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void addMappingLoaderFuture(Class<? extends Protocol> protocolClass, Runnable runnable) {
|
private static Function<Throwable, Void> mappingLoaderThrowable(Class<? extends Protocol> protocolClass) {
|
||||||
synchronized (MAPPING_LOADER_LOCK) {
|
return throwable -> {
|
||||||
CompletableFuture<Void> future = CompletableFuture.runAsync(runnable, mappingLoaderExecutor).exceptionally(throwable -> {
|
Via.getPlatform().getLogger().severe("Error during mapping loading of " + protocolClass.getSimpleName());
|
||||||
Via.getPlatform().getLogger().severe("Error during mapping loading of " + protocolClass.getSimpleName());
|
throwable.printStackTrace();
|
||||||
throwable.printStackTrace();
|
return null;
|
||||||
return null;
|
};
|
||||||
});
|
|
||||||
mappingLoaderFutures.put(protocolClass, future);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void addMappingLoaderFuture(Class<? extends Protocol> protocolClass, Class<? extends Protocol> dependsOn, Runnable runnable) {
|
|
||||||
synchronized (MAPPING_LOADER_LOCK) {
|
|
||||||
CompletableFuture<Void> future = getMappingLoaderFuture(dependsOn)
|
|
||||||
.whenCompleteAsync((v, throwable) -> runnable.run(), mappingLoaderExecutor).exceptionally(throwable -> {
|
|
||||||
Via.getPlatform().getLogger().severe("Error during mapping loading of " + protocolClass.getSimpleName());
|
|
||||||
throwable.printStackTrace();
|
|
||||||
return null;
|
|
||||||
});
|
|
||||||
mappingLoaderFutures.put(protocolClass, future);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Nullable
|
|
||||||
public static CompletableFuture<Void> getMappingLoaderFuture(Class<? extends Protocol> protocolClass) {
|
|
||||||
synchronized (MAPPING_LOADER_LOCK) {
|
|
||||||
if (mappingsLoaded) return null;
|
|
||||||
return mappingLoaderFutures.get(protocolClass);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Laden…
In neuem Issue referenzieren
Einen Benutzer sperren