Repo-Mirror/AkarinMC
9
0
Fork 0
Code Issues Pull Requests Releases Activity

Remove unneed synchronization

Browse Source
This commit is contained in:
Sotr
2018-08-01 23:57:27 +08:00
parent 6e62515d11
commit a0545a756d
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
sources/src/main/java/net/minecraft/server/ChunkRegionLoader.java
View File

@@ -1,16 +1,11 @@
package net.minecraft.server; package net.minecraft.server;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import java.io.DataInputStream;
import java.io.DataOutput;
import java.io.DataOutputStream;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.util.Collections;
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set;
import javax.annotation.Nullable; import javax.annotation.Nullable;
import java.util.concurrent.ConcurrentLinkedQueue; // Paper import java.util.concurrent.ConcurrentLinkedQueue; // Paper
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
@@ -20,6 +15,10 @@ import java.util.function.Supplier;
import org.spigotmc.SupplierUtils; import org.spigotmc.SupplierUtils;
// Spigot end // Spigot end
/**
* Akarin Changes Note
* 1) Removes unneed synchronization (performance)
*/
public class ChunkRegionLoader implements IChunkLoader, IAsyncChunkSaver { public class ChunkRegionLoader implements IChunkLoader, IAsyncChunkSaver {
private ConcurrentLinkedQueue<QueuedChunk> queue = new ConcurrentLinkedQueue<>(); // Paper - Chunk queue improvements private ConcurrentLinkedQueue<QueuedChunk> queue = new ConcurrentLinkedQueue<>(); // Paper - Chunk queue improvements
@@ -180,7 +179,7 @@ public class ChunkRegionLoader implements IChunkLoader, IAsyncChunkSaver {
return this.processSaveQueueEntry(false); return this.processSaveQueueEntry(false);
} }
private synchronized boolean processSaveQueueEntry(boolean logCompletion) { private /*synchronized*/ boolean processSaveQueueEntry(boolean logCompletion) { // Akarin - remove synchronization
// CraftBukkit start // CraftBukkit start
// Paper start - Chunk queue improvements // Paper start - Chunk queue improvements
QueuedChunk chunk = queue.poll(); QueuedChunk chunk = queue.poll();