projectswg/Holocore
1
0
Fork 0
mirror of https://github.com/ProjectSWGCore/Holocore.git synced 2026-10-18 08:02:56 -04:00
Code Issues Projects Releases Wiki Activity

Using ThreadUtilities to name thread pools for easier debugging

Browse Source
This commit is contained in:
Obique
2015-05-16 03:16:05 -05:00
committed by Obique
parent 2ef55fdc70
commit 4e18d19cd8
3 changed files with 5 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/services/chat/ChatService.java
-52
View File
@@ -31,11 +31,6 @@ import java.util.Date;
import java.util.LinkedList;
import java.util.List;
import java.util.Locale;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
import intents.GalacticPacketIntent;
import intents.NotifyPlayersPacketIntent;
@@ -60,7 +55,6 @@ import network.packets.swg.zone.chat.ChatSystemMessage.SystemChatType;
import network.packets.swg.zone.object_controller.SpatialChat;
import resources.Terrain;
import resources.control.Intent;
import resources.control.ServerStatus;
import resources.control.Service;
import resources.encodables.OutOfBand;
import resources.encodables.ProsePackage;
@@ -123,11 +117,6 @@ public class ChatService extends Service {
if (i instanceof ChatBroadcastIntent)
handleChatBroadcast((ChatBroadcastIntent) i);
break;
case ServerStatusIntent.TYPE:
if (i instanceof ServerStatusIntent)
if (((ServerStatusIntent)i).getStatus() == ServerStatus.SHUTDOWN_REQUESTED)
sendShutdownBroadcasts((ServerStatusIntent) i);
break;
}
}
@@ -311,47 +300,6 @@ public class ChatService extends Service {
player.sendPacket(new ChatSystemMessage(SystemChatType.SCREEN_AND_CHAT, pckg));
}
private void sendShutdownBroadcasts(ServerStatusIntent i) {
final TimeUnit timeUnit = i.getTimeUnit();
final long time = i.getTime();
final TimeUnit broadcastUnit = TimeUnit.NANOSECONDS;
final long timeNanoSeconds = broadcastUnit.convert(time, timeUnit);
final AtomicLong intervalCount = new AtomicLong((long) Math.ceil(Math.sqrt(Math.sqrt(timeNanoSeconds)) / 200));
final ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
final AtomicInteger runCount = new AtomicInteger();
final AtomicLong timeRemaining = new AtomicLong(time);
final long timeBetweenBroadcasts;
final String finalShutdownMessage = "The server will now be shutting down.";
if(intervalCount.get() > timeNanoSeconds)
intervalCount.set(time);
if(time > 0) {
timeBetweenBroadcasts = timeNanoSeconds / intervalCount.get();
executor.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
String message;
long timeRemainingVal = timeRemaining.get();
if(runCount.getAndIncrement() == intervalCount.get()) {
message = finalShutdownMessage;
executor.shutdown();
} else {
String unitName = timeUnit.name().toLowerCase(Locale.ENGLISH);
message = String.format("The server will be shutting down in %d %s", timeRemainingVal, unitName.substring(0, unitName.length() - 1));
message += (timeRemainingVal == 1 ? "" : "s") + ".";
timeRemaining.set(timeRemainingVal - timeUnit.convert(timeBetweenBroadcasts, broadcastUnit));
}
broadcastGalaxyMessage(message, null);
}
}, 0, timeBetweenBroadcasts, broadcastUnit);
} else
broadcastGalaxyMessage(finalShutdownMessage, null);
}
private void sendPersistentMessageHeaders(Player player, String galaxy) {
if (player == null || player.getCreatureObject() == null)
return;