1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
if(!dojo._hasResource["dojox.timing.ThreadPool"]){ //_hasResource checks added by build. Do not use _hasResource directly in your code.
dojo._hasResource["dojox.timing.ThreadPool"] = true;
dojo.provide("dojox.timing.ThreadPool");
dojo.require("dojox.timing");
dojo.experimental("dojox.timing.ThreadPool");
// dojox.timing.Timer is included as part of _base
/********************************************************************
This is a port of the original System.Threading.ThreadPool from
the f(m) class library.
Donated to the Dojo toolkit by the author :)
*********************************************************************/
(function(){
var t=dojox.timing;
t.threadStates={
UNSTARTED:"unstarted",
STOPPED:"stopped",
PENDING:"pending",
RUNNING:"running",
SUSPENDED:"suspended",
WAITING:"waiting",
COMPLETE:"complete",
ERROR:"error"
};
// Before rar says a word, we actually *use* these numbers for a purpose :)
t.threadPriorities={
LOWEST:1,
BELOWNORMAL:2,
NORMAL:3,
ABOVENORMAL:4,
HIGHEST:5
};
t.Thread=function(/* Function */fn, /* dojox.timing.threadPriorities? */priority){
var self=this;
this.state=t.threadStates.UNSTARTED;
this.priority=priority||t.threadPriorities.NORMAL;
this.lastError=null;
this.func=fn; // for lookup purposes.
this.invoke=function(){
self.state=t.threadStates.RUNNING;
try{
fn(this);
self.state=t.threadStates.COMPLETE;
}catch(e){
self.lastError=e;
self.state=t.threadStates.ERROR;
}
};
};
// TODO: allow for changing of maxThreads and tick interval
t.ThreadPool=new (function(/* Number */mxthrs, /* Number */intvl){
var self=this;
var maxThreads=mxthrs;
var availableThreads=maxThreads;
var interval=intvl;
var fireInterval=Math.floor((interval/2)/maxThreads);
var queue=[];
var timers=new Array(maxThreads+1);
var timer=new dojox.timing.Timer();
var invoke=function(){
var tracker=timers[0]={};
for(var i=0; i<timers.length; i++){
window.clearTimeout(timers[i]);
var thread=queue.shift();
if(typeof(thread)=="undefined"){ break; }
tracker["thread-"+i]=thread;
timers[i]=window.setTimeout(thread.invoke,(fireInterval*i));
}
availableThreads=maxThreads-(i-1);
};
// public methods
this.getMaxThreads=function(){ return maxThreads; };
this.getAvailableThreads=function(){ return availableThreads; };
this.getTickInterval=function(){ return interval; };
this.queueUserWorkItem=function(/* Function || dojox.timing.Thread */fn){
var item=fn;
if(item instanceof Function){
item=new t.Thread(item);
}
var idx=queue.length;
for(var i=0; i<queue.length; i++){
if(queue[i].priority<item.priority){
idx=i;
break;
}
}
if(idx<queue.length){
queue.splice(idx, 0, item);
} else {
queue.push(item);
}
return true;
};
this.removeQueuedUserWorkItem=function(/* Function || dojox.timing.Thread */item){
if(item instanceof Function){
var idx=-1;
for(var i=0; i<queue.length; i++){
if(queue[i].func==item){
idx=i;
break;
}
}
if(idx>-1){
queue.splice(idx,1);
return true;
}
return false;
}
var idx=-1;
for(var i=0; i<queue.length; i++){
if(queue[i]==item){
idx=i;
break;
}
}
if(idx>-1){
queue.splice(idx,1);
return true;
}
return false;
};
this.start=function(){ timer.start(); };
this.stop=function(){ timer.stop(); };
this.abort=function(){
this.stop();
for(var i=1; i<timers.length; i++){
if(timers[i]){
window.clearTimeout(timers[i]);
}
}
for(var thread in timers[0]){
this.queueUserWorkItem(thread);
}
timers[0]={};
};
this.reset=function(){
this.abort();
queue=[];
};
this.sleep=function(/* Number */nSleep){
timer.stop();
window.setTimeout(timer.start, nSleep);
};
// dedicate the timer to us.
timer.onTick=self.invoke;
})(16, 5000);
})();
}
|
