mirrors/PocketMine-MP
1
0
Fork 0
mirror of https://github.com/pmmp/PocketMine-MP.git synced 2025-06-12 06:25:32 +00:00
Code Issues Projects Releases Wiki Activity

Some minor cleanup of PocketMine.php

Browse Source
This commit is contained in:
Dylan K. Taylor 2017-09-13 19:14:31 +01:00
parent be27e03126
commit c283d87494
2 changed files with 22 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/pocketmine/PocketMine.php
View File

@ -558,19 +558,7 @@ namespace pocketmine {
$killer->start(); $killer->start();
usleep(10000); //Fixes ServerKiller not being able to start on single-core machines usleep(10000); //Fixes ServerKiller not being able to start on single-core machines
$erroredThreads = 0; if(ThreadManager::getInstance()->stopAll() > 0){
foreach(ThreadManager::getInstance()->getAll() as $id => $thread){
$logger->debug("Stopping " . $thread->getThreadName() . " thread");
try{
$thread->quit();
$logger->debug($thread->getThreadName() . " thread stopped successfully.");
}catch(\ThreadException $e){
++$erroredThreads;
$logger->debug("Could not stop " . $thread->getThreadName() . " thread: " . $e->getMessage());
}
}
if($erroredThreads > 0){
if(\pocketmine\DEBUG > 1){ if(\pocketmine\DEBUG > 1){
echo "Some threads could not be stopped, performing a force-kill" . PHP_EOL . PHP_EOL; echo "Some threads could not be stopped, performing a force-kill" . PHP_EOL . PHP_EOL;
} }

21
src/pocketmine/ThreadManager.php
View File

@ -23,6 +23,8 @@ declare(strict_types=1);
namespace pocketmine; namespace pocketmine;
use pocketmine\utils\MainLogger;
class ThreadManager extends \Volatile{ class ThreadManager extends \Volatile{
/** @var ThreadManager */ /** @var ThreadManager */
@ -68,4 +70,23 @@ class ThreadManager extends \Volatile{
return $array; return $array;
} }
public function stopAll() : int{
$logger = MainLogger::getLogger();
$erroredThreads = 0;
foreach($this->getAll() as $thread){
$logger->debug("Stopping " . $thread->getThreadName() . " thread");
try{
$thread->quit();
$logger->debug($thread->getThreadName() . " thread stopped successfully.");
}catch(\ThreadException $e){
++$erroredThreads;
$logger->debug("Could not stop " . $thread->getThreadName() . " thread: " . $e->getMessage());
}
}
return $erroredThreads;
}
} }