FilesExpand file tree

 travis

/

Thread.js

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

100 lines (87 loc) · 2.71 KB

 travis

/

Thread.js

Copy path

Top

File metadata and controls

• Code
• Blame

100 lines (87 loc) · 2.71 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

var Thread = {

hostRunning: true,

activeLoops: 0,

_timers: [],

spin: function(ctrl) {

ctrl.startTime = ctrl.startTime || Date.now();

ctrl.timeout = false;

this.activeLoops++;

this._spinInternal(ctrl);

this.activeLoops--;

ctrl.elapsed = Date.now() - ctrl.startTime;

return ctrl.timeout;

},

_spinInternal: function(ctrl) {

var t = ctrl.startTime;

var maxTime = parseInt(ctrl.maxTime);

if (maxTime) {

while(ctrl.running && this.hostRunning) {

this.yield();

if (Date.now() - t > maxTime) {

ctrl.timeout = true;

ctrl.running = false;

break;

}

}

} else while(ctrl.running && this.hostRunning) this.yield();

},

yield: function() {

this.current.processNextEvent(true);

},

yieldAll: function() {

var t = this.current;

while(t.hasPendingEvents()) t.processNextEvent(false);

},

get current() {

delete this.current;

var obj = "@mozilla.org/thread-manager;1" in Cc

? Cc["@mozilla.org/thread-manager;1"].getService()

: Cc["@mozilla.org/thread;1"].createInstance(Ci.nsIThread);

this.__defineGetter__("current", function() { return obj.currentThread; });

return this.current;

},

get currentQueue() {

delete this.currentQueue;

var eqs = null;

const CTRID = "@mozilla.org/event-queue-service;1";

if (CTRID in Cc) {

const IFace = Ci.nsIEventQueueService;

eqs = Cc[CTRID].getService(IFace);

}

this.__defineGetter__("currentQueue", eqs

? function() { return eqs.getSpecialEventQueue(IFace.CURRENT_THREAD_EVENT_QUEUE); }

: this.__lookupGetter__("current")

);

return this.currentQueue;

},

delay: function(callback, time, self, args) {

var timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer);

this._timers.push(timer);

timer.initWithCallback({

notify: this._delayRunner,

context: { callback: callback, args: args || DUMMY_ARRAY, self: self || null }

}, time || 1, 0);

},

dispatch: function(runnable) {

this.current.dispatch(runnable, Ci.nsIEventTarget.DISPATCH_NORMAL);

},

asap: function(callback, self, args) {

this.current.dispatch({

run: function() {

callback.apply(self, args || DUMMY_ARRAY);

}

}, Ci.nsIEventTarget.DISPATCH_NORMAL);

},

_delayRunner: function(timer) {

var ctx = this.context;

try {

ctx.callback.apply(ctx.self, ctx.args);

} finally {

this.context = null;

var tt = Thread._timers;

var pos = tt.indexOf(timer);

if (pos > -1) tt.splice(pos, 1);

timer.cancel();

}

}

};