Index: Source/devtools/front_end/common/Throttler.js |
diff --git a/Source/devtools/front_end/common/Throttler.js b/Source/devtools/front_end/common/Throttler.js |
new file mode 100644 |
index 0000000000000000000000000000000000000000..fc6803a9538a5a16874bdf1bbb1968c9d9c85ac8 |
--- /dev/null |
+++ b/Source/devtools/front_end/common/Throttler.js |
@@ -0,0 +1,70 @@ |
+// Copyright 2014 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+/** |
+ * @constructor |
+ * @param {number} timeout |
+ */ |
+WebInspector.Throttler = function(timeout) |
aandrey
2014/06/10 15:08:38
IMO, the most common use case in our code is: send
|
+{ |
+ this._timeout = timeout; |
+ this._isRunningProcess = false; |
+ this._processTimeout = null; |
aandrey
2014/06/10 14:59:53
remove
|
+ this._asSoonAsPossible = false; |
+ this._process = null; |
aandrey
2014/06/10 14:59:53
jsdoc
lushnikov
2014/06/10 16:05:09
Done.
|
+} |
+ |
+WebInspector.Throttler.prototype = { |
+ _processCompleted: function() |
+ { |
+ this._isRunningProcess = false; |
+ if (this._process) |
+ this._innerSchedule(); |
+ }, |
+ |
+ _onTimeout: function() |
+ { |
+ this._processTimeout = null; |
aandrey
2014/06/10 14:59:53
delete this._processTimeout;
lushnikov
2014/06/10 16:05:09
Done.
|
+ this._asSoonAsPossible = false; |
+ this._isRunningProcess = true; |
+ |
+ // Process might issue synchronous calls to this throttler. |
+ var process = this._process; |
+ this._process = null; |
+ process(this._processCompleted.bind(this)); |
+ }, |
+ |
+ /** |
+ * @param {function(!WebInspector.Throttler.FinishCallback)} process |
+ * @param {boolean=} asSoonAsPossible |
+ */ |
+ schedule: function(process, asSoonAsPossible) |
+ { |
+ // Deliberately skip previous process. |
+ this._process = process; |
vsevik
2014/06/10 11:39:00
var force = asSoonAsPossible && !this._asSoonAsPos
lushnikov
2014/06/10 16:05:09
Done.
|
+ this._asSoonAsPossible = this._asSoonAsPossible || !!asSoonAsPossible; |
+ |
+ if (this._isRunningProcess) |
+ return; |
+ |
+ this._innerSchedule(); |
+ }, |
+ |
+ _innerSchedule: function() |
+ { |
+ if (this._processTimeout && !this._asSoonAsPossible) |
vsevik
2014/06/10 11:39:00
if (this._processTimeout && !force)
return;
lushnikov
2014/06/10 16:05:09
Done.
|
+ return; |
+ if (this._processTimeout && this._asSoonAsPossible) |
+ clearTimeout(this._processTimeout); |
+ |
+ // Pretend the process is running to avoid timer rescheduling. |
+ this._isRunningProcess = this._asSoonAsPossible; |
dgozman
2014/06/09 19:43:11
If you clear |this._asSoonAsPossible| here:
- no n
lushnikov
2014/06/10 09:05:22
1. Consider having for-loop, which does throttler.
|
+ |
+ var timeout = this._asSoonAsPossible ? 0 : this._timeout; |
+ this._processTimeout = setTimeout(this._onTimeout.bind(this), timeout); |
+ } |
+} |
+ |
+/** @typedef {function()} */ |
+WebInspector.Throttler.FinishCallback; |