Public Member Functions
	getClassLoader ()

	setClassLoader (\ClassLoader $loader=null)

	registerClassLoader ()

	start (int $options=PTHREADS_INHERIT_ALL)

	quit ()

	getThreadName ()

Public Member Functions inherited from Worker
	getStacked ()

	isShutdown ()

	collector (Collectable $collectable)

	shutdown ()

	stack (Collectable &$work)

	unstack ()

	collect (callable $function)

Public Member Functions inherited from Thread
	getCreatorId ()

	getThreadId ()

	isJoined ()

	isStarted ()

	join ()

	start (int $options=PTHREADS_INHERIT_ALL)

Public Member Functions inherited from Threaded
	chunk ($size, bool $preserve=false)

	count ()

	isRunning ()

	isTerminated ()

	merge ($from, $overwrite=true)

	notify ()

	notifyOne ()

	offsetGet ($offset)

	offsetSet ($offset, $value)

	offsetExists ($offset)

	offsetUnset ($offset)

	pop ()

	run ()

	shift ()

	synchronized (\Closure $function, $args=null)

	wait ($timeout)

	getRefCount ()

	addRef ()

	delRef ()

	isGarbage ()

Protected Attributes
	$classLoader

	$isKilled = false

Additional Inherited Members
Static Public Member Functions inherited from Thread
static	getCurrentThread ()

static	getCurrentThreadId ()

Static Public Member Functions inherited from Threaded
static	extend ($obj)

Detailed Description

This class must be extended by all custom threading classes

Member Function Documentation

◆ getClassLoader()

getClassLoader ( )

Returns

                                     {
         return $this->classLoader;
     }

◆ getThreadName()

getThreadName ( )

Returns: string

                                    {
         return (new \ReflectionClass($this))->getShortName();
     }

◆ quit()

quit ( )

Stops the thread using the best way possible. Try to stop it yourself before calling this.

                           {
         $this->isKilled = true;
 
         $this->notify();
 
         if($this->isRunning()){
             $this->shutdown();
             $this->notify();
             $this->unstack();
         }elseif(!$this->isJoined()){
             if(!$this->isTerminated()){
                 $this->join();
             }
         }
 
         ThreadManager::getInstance()->remove($this);
     }

◆ registerClassLoader()

registerClassLoader ( )

                                          {
         if(!interface_exists("ClassLoader", false)){
             require(\pocketmine\PATH . "src/spl/ClassLoader.php");
             require(\pocketmine\PATH . "src/spl/BaseClassLoader.php");
         }
         if($this->classLoader !== null){
             $this->classLoader->register(true);
         }
     }

◆ setClassLoader()

setClassLoader ( \ClassLoader $loader = null )

Parameters

\ClassLoader | null $loader

                                                                {
         if($loader === null){
             $loader = Server::getInstance()->getLoader();
         }
         $this->classLoader = $loader;
     }

◆ start()

start ( int $options = PTHREADS_INHERIT_ALL )

Parameters

int $options

Returns: bool

                                                               {
         ThreadManager::getInstance()->add($this);
 
         if(!$this->isRunning() and !$this->isJoined() and !$this->isTerminated()){
             if($this->getClassLoader() === null){
                 $this->setClassLoader();
             }
             return parent::start($options);
         }
 
         return false;
     }

Field Documentation

◆ $classLoader

$classLoader

protected

◆ $isKilled

$isKilled = false