cyberpresidentvanellope/Aurora.3
1
0
Fork 0
mirror of https://github.com/Aurorastation/Aurora.3.git synced 2025-12-24 00:51:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Renames the process to scheduler.

Browse Source
This commit is contained in:
PsiOmegaDelta
2015-11-30 11:18:58 +01:00
parent 9c9d7f0356
commit 840959f1f1
3 changed files with 82 additions and 82 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
code/controllers/Processes/general.dm
View File

@@ -1,81 +0,0 @@
var/global/list/general_tasks
/datum/controller/process/general/setup()
name = "general"
schedule_interval = 7 SECONDS
general_tasks = list()
/datum/controller/process/general/doWork()
for(last_object in general_tasks)
var/datum/general_task/general_task = last_object
try
if(world.time > general_task.trigger_time)
general_tasks -= general_task
general_task.process()
catch(var/exception/e)
catchException(e, last_object)
SCHECK
/datum/controller/process/general/statProcess()
..()
stat(null, "[general_tasks.len] tasks")
/*************
* Task Datum *
*************/
/datum/general_task
var/trigger_time
var/procedure
var/list/arguments
var/task_after_process
var/list/task_after_process_args
/datum/general_task/New(var/trigger_time, var/procedure, var/list/arguments, var/proc/task_after_process, var/list/task_after_process_args)
src.trigger_time = trigger_time
src.procedure = procedure
src.arguments = arguments ? arguments : list()
src.task_after_process = task_after_process ? task_after_process : /proc/destroy_general_task
src.task_after_process_args = istype(task_after_process_args) ? task_after_process_args : list()
task_after_process_args += src
general_tasks += src
/datum/general_task/Destroy()
general_tasks -= src
procedure = null
arguments.Cut()
task_after_process = null
task_after_process_args.Cut()
return ..()
/datum/general_task/proc/process()
call(procedure)(arglist(arguments))
after_process()
/datum/general_task/proc/after_process()
call(task_after_process)(arglist(task_after_process_args))
/datum/general_task/source
var/datum/source
/datum/general_task/source/New(var/trigger_time, var/datum/source, var/procedure, var/list/arguments, var/proc/task_after_process, var/list/task_after_process_args)
src.source = source
src.source.register(OBSERVER_EVENT_DESTROY, src, /datum/general_task/source/proc/source_destroyed)
..(trigger_time, procedure, arguments, task_after_process, task_after_process_args)
/datum/general_task/source/Destroy()
source = null
return ..()
/datum/general_task/source/process()
call(source, procedure)(arglist(arguments))
after_process()
/datum/general_task/source/proc/source_destroyed()
qdel(src)
/proc/destroy_general_task(var/datum/general_task/gt)
qdel(gt)
/proc/repeat_general_task(var/trigger_delay, var/datum/general_task/gt)
gt.trigger_time = world.time + trigger_delay
general_tasks += gt

81
code/controllers/Processes/scheduler.dm Normal file
View File

@@ -0,0 +1,81 @@
var/global/list/scheduled_tasks
/datum/controller/process/scheduler/setup()
name = "scheduler"
schedule_interval = 7 SECONDS
scheduled_tasks = list()
/datum/controller/process/scheduler/doWork()
for(last_object in scheduled_tasks)
var/datum/scheduled_task/scheduled_task = last_object
try
if(world.time > scheduled_task.trigger_time)
scheduled_tasks -= scheduled_task
scheduled_task.process()
catch(var/exception/e)
catchException(e, last_object)
SCHECK
/datum/controller/process/scheduler/statProcess()
..()
stat(null, "[scheduled_tasks.len] tasks")
/*************
* Task Datum *
*************/
/datum/scheduled_task
var/trigger_time
var/procedure
var/list/arguments
var/task_after_process
var/list/task_after_process_args
/datum/scheduled_task/New(var/trigger_time, var/procedure, var/list/arguments, var/proc/task_after_process, var/list/task_after_process_args)
src.trigger_time = trigger_time
src.procedure = procedure
src.arguments = arguments ? arguments : list()
src.task_after_process = task_after_process ? task_after_process : /proc/destroy_scheduled_task
src.task_after_process_args = istype(task_after_process_args) ? task_after_process_args : list()
task_after_process_args += src
scheduled_tasks += src
/datum/scheduled_task/Destroy()
scheduled_tasks -= src
procedure = null
arguments.Cut()
task_after_process = null
task_after_process_args.Cut()
return ..()
/datum/scheduled_task/proc/process()
call(procedure)(arglist(arguments))
after_process()
/datum/scheduled_task/proc/after_process()
call(task_after_process)(arglist(task_after_process_args))
/datum/scheduled_task/source
var/datum/source
/datum/scheduled_task/source/New(var/trigger_time, var/datum/source, var/procedure, var/list/arguments, var/proc/task_after_process, var/list/task_after_process_args)
src.source = source
src.source.register(OBSERVER_EVENT_DESTROY, src, /datum/scheduled_task/source/proc/source_destroyed)
..(trigger_time, procedure, arguments, task_after_process, task_after_process_args)
/datum/scheduled_task/source/Destroy()
source = null
return ..()
/datum/scheduled_task/source/process()
call(source, procedure)(arglist(arguments))
after_process()
/datum/scheduled_task/source/proc/source_destroyed()
qdel(src)
/proc/destroy_scheduled_task(var/datum/scheduled_task/gt)
qdel(gt)
/proc/repeat_scheduled_task(var/trigger_delay, var/datum/scheduled_task/gt)
gt.trigger_time = world.time + trigger_delay
scheduled_tasks += gt