Планировщик задач на JavaScript

Иногда на клиентской стороне необходимо выполнять фоновые задачи. Главное требование чтобы они не прерывали работу всего веб-приложения а, спокойно в фоновом режиме общались между собой, завершались и добавлялись. Цель предложенного планировщика снять с разработчика головную боль о таких задачах и свести к общему интерфейсу, с помощью которого можно постепенно расширять спектр решаемых задач.

HClass.Define("HFlag", { extend : HCore.Object, static : {

MAX_FLAG_VALUE : 65535

}, props: {

dwFlag : null,

construct : function(dwFlag) { this.Add(dwFlag); return this; },

Set : function(dwFlag) { this.dwFlag = dwFlag; },
Get : function() { return this.dwFlag; },
Add : function(dwFlag) { this.dwFlag |= dwFlag; },
Zero : function(dwFlag) { this.dwFlag &= (HFlag.MAX_FLAG_VALUE - dwFlag); },
Check : function(dwFlag) { return !!(this.dwFlag & dwFlag); },
Swap : function(dwNew, dwOld) { this.Zero(dwOld); this.Add(dwNew); },
Clear : function() { this.Set(0); }
}});

* This source code was highlighted with Source Code Highlighter.

RunTask : function(pTask) {
pTask.nTaskId = this.nTotalTasks;
this.aTaskHeap[this.nTotalTasks++] = pTask;
pTask.nTimerId = setInterval("HSheduler.aTaskHeap[" + pTask.nTaskId + "].Cycle()", pTask.nCycleTimeout);
},

RemoveTask : function(pTask) {
clearInterval(pTask.nTimerId);
delete this.aTaskHeap[pTask.nTaskId];
}

* This source code was highlighted with Source Code Highlighter.

Cycle : function() {
if(!this.pStaticAddress) return;
if(this.oStateFlags.Check(HBaseTask.SF_Remove)) {
this.Remove();
return;
}
if(!this.oStateFlags.Check(HBaseTask.SF_Wait)) {
if(!this.oStateFlags.Check(HBaseTask.SF_SkipCycle)) {
this.pStaticAddress.apply(this, this.oTaskParams);
this.nCyclesCount++;
} else this.oStateFlags.Zero(HBaseTask.SF_SkipCycle);
}
this.oStateFlags.Zero(HBaseTask.SF_SetParams);
}

* This source code was highlighted with Source Code Highlighter.

//
// Sheduler.
//

HClass.Define("HSheduler", { static : {

nTotalTasks : 0,
aTaskHeap : [],

RunTask : function(pTask) {
pTask.nTaskId = this.nTotalTasks;
this.aTaskHeap[this.nTotalTasks++] = pTask;
pTask.nTimerId = setInterval("HSheduler.aTaskHeap[" + pTask.nTaskId + "].Cycle()", pTask.nCycleTimeout);
},

RemoveTask : function(pTask) {
clearInterval(pTask.nTimerId);
delete this.aTaskHeap[pTask.nTaskId];
},

//
// Base Task.
//

HBaseTask : HClass.Define("HBaseTask", { extend : HProcess, static : {

TF_Nothing : 0,
TF_FireRun : 1,

SF_Null : 0,
SF_Ready : 1,
SF_Process : 2,
SF_SetParams : 4,
SF_SkipCycle : 8,
SF_Remove : 16,
SF_Wait : 32

}, props : {

oTaskFlags : null,
oStateFlags : null,
oTaskParams : null,
nTaskId : null,
nTimerId : null,
nCycleTimeout : 1000,
nCyclesCount : 0,
nCyclesLimit : 0,

construct : function(fCode) {
this.oTaskFlags = new HFlag(HBaseTask.TF_Nothing);
this.oStateFlags = new HFlag(HBaseTask.SF_Ready);
this.nCycleTimeout = 1000; // ms.
this.nCyclesCount = 0;
this.nCyclesLimit = 0;
if(fCode) this.Create(fCode);
return this;
},

Run : function() { HSheduler.RunTask(this); },
Remove : function() { HSheduler.RemoveTask(this); },

Params : function() {
this.oTaskParams = arguments;
this.oStateFlags.Add(HBaseTask.SF_SetParams);
},

CycleTimeout : function(nCycleTimeout) { this.nCycleTimeout = nCycleTimeout; },

Cycle : function() {
if(!this.pStaticAddress) return;
if(this.oStateFlags.Check(HBaseTask.SF_Remove)) {
this.Remove();
return;
}
if(!this.oStateFlags.Check(HBaseTask.SF_Wait)) {
if(!this.oStateFlags.Check(HBaseTask.SF_SkipCycle)) {
this.pStaticAddress.apply(this, this.oTaskParams);
this.nCyclesCount++;
} else this.oStateFlags.Zero(HBaseTask.SF_SkipCycle);
}
this.oStateFlags.Zero(HBaseTask.SF_SetParams);
},

AddState : function(dwFlag) { this.oStateFlags.Add(dwFlag); },
SwapState : function(dwNew, dwOld) { this.oStateFlags.Swap(dwNew, dwOld); },
GetState : function() { return this.oStateFlags; }
}})
}});

* This source code was highlighted with Source Code Highlighter.

// Пример простой задачи она будет работать в цикле.
var pTask = HBaseTask(function() { alert("Hello world!"); });
pTask.Run();

// Пример задачи получающей параметры.
var pTask = HBaseTask(function(a, b) { alert(a + " " + b); });
pTask.Params(32, 128);
pTask.Run();

// Пример задачи управляющей соcтояниями.
var pTask = HBaseTask(function() {
var oState = this.GetState(); // Берем текущее состояние.
if(oState.Check(HBaseTask.SF_Ready)) {
// Тут подготавливаем производные переменные или создаем нужные объекты, например XHR.
this.SwapState(HBaseTask.SF_Process, HBaseTask.SF_Ready);
} else if(oState.Check(HBaseTask.SF_Process)) {
// Здесь что то считаем и если получаем результат переходим с состояние завершения
this.SwapState(HBaseTask.SF_Remove, HBaseTask.SF_Process);
}
});
pTask.Run();

* This source code was highlighted with Source Code Highlighter.

HClass.Define("HLerpTask", { extend : HBaseTask, props : {

fStart : 0, fEnd : 0,
fStep : 0, fT : 0,
fRange : 0,
fCallback : null,

EvalLerp : function() { return this.fStart + this.fT * this.fRange; },

construct : function(fStart, fEnd, fStep, fCallback) {
this.fStart = fStart;
this.fEnd = fEnd;
this.fStep = fStep;
this.fCallback = fCallback;
this.CycleTimeout(10);
this.Create(function() {
var oState = this.GetState();
if(oState.Check(HBaseTask.SF_Ready)) {
this.fT = 0;
this.fRange = this.fEnd - this.fStart;
this.SwapState(HBaseTask.SF_Process, HBaseTask.SF_Ready);
} else if(oState.Check(HBaseTask.SF_Process)) {
this.fT += this.fStep;
if(this.fT >= 1.0) {
this.fT = 1.0;
this.SwapState(HBaseTask.SF_Remove, HBaseTask.SF_Process);
}
if(this.fCallback) this.fCallback(this.EvalLerp());
}
});
}
}});

* This source code was highlighted with Source Code Highlighter.

function GE(sId) { return document.getElementById(sId); }

var pTask = new HLerpTask(0, 100, 0.001, function(fRet) { GE("counter1").innerHTML = fRet; });
var pTask2 = new HLerpTask(0, 1000, 0.0005, function(fRet) { GE("counter2").innerHTML = fRet; });

pTask.Run();
pTask2.Run();

* This source code was highlighted with Source Code Highlighter.