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

Disallow scheduling the same AsyncTask instance more than once

Browse Source
This commit is contained in:
SOFe 2016-11-11 22:53:20 +08:00
parent f0f6d85809
commit da23568546
No known key found for this signature in database
GPG Key ID: A0379676C4D9D5D9
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/pocketmine/scheduler/ServerScheduler.php
View File

@ -76,6 +76,9 @@ class ServerScheduler{
* @return void * @return void
*/ */
public function scheduleAsyncTask(AsyncTask $task){ public function scheduleAsyncTask(AsyncTask $task){
if($task->getTaskId() !== null){
throw new \UnexpectedValueException("Attempt to schedule the same AsyncTask instance twice");
}
$id = $this->nextId(); $id = $this->nextId();
$task->setTaskId($id); $task->setTaskId($id);
$task->progressUpdates = new \Threaded; $task->progressUpdates = new \Threaded;
@ -91,6 +94,9 @@ class ServerScheduler{
* @return void * @return void
*/ */
public function scheduleAsyncTaskToWorker(AsyncTask $task, $worker){ public function scheduleAsyncTaskToWorker(AsyncTask $task, $worker){
if($task->getTaskId() !== null){
throw new \UnexpectedValueException("Attempt to schedule the same AsyncTask instance twice");
}
$id = $this->nextId(); $id = $this->nextId();
$task->setTaskId($id); $task->setTaskId($id);
$task->progressUpdates = new \Threaded; $task->progressUpdates = new \Threaded;