diff options
Diffstat (limited to 'trunk/infrastructure/net.appjet.ajstdlib/timer.scala')
-rw-r--r-- | trunk/infrastructure/net.appjet.ajstdlib/timer.scala | 85 |
1 files changed, 0 insertions, 85 deletions
diff --git a/trunk/infrastructure/net.appjet.ajstdlib/timer.scala b/trunk/infrastructure/net.appjet.ajstdlib/timer.scala deleted file mode 100644 index dac8fb6..0000000 --- a/trunk/infrastructure/net.appjet.ajstdlib/timer.scala +++ /dev/null @@ -1,85 +0,0 @@ -/** - * Copyright 2009 Google Inc. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS-IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package net.appjet.ajstdlib; - -import scala.collection.mutable.{HashMap,ListBuffer}; -import java.util.concurrent.locks.ReentrantLock; - -object timer { - - var _timings = new HashMap[String,ListBuffer[double]]; - var _lock = new ReentrantLock; - var _callstack = new ThreadLocal[ListBuffer[String]]; - - def start(opname: String) = { - var _localcallstack = _callstack.get(); - if (_localcallstack == null) { - _callstack.set(new ListBuffer[String]); - _localcallstack = _callstack.get(); - } - _localcallstack += opname; - var _oplabel = _localcallstack.mkString("."); - val startTime: long = System.nanoTime(); - - new { - def done() { - val elapsedTimeMs: double = (System.nanoTime() - startTime) / 1.0e6; - - _lock.lock(); - try { - var times = _timings.getOrElse(_oplabel, new ListBuffer[double]); - /* - if (times.size > 100000) { - times = new ListBuffer[double]; - }*/ - times += elapsedTimeMs; - _timings.put(_oplabel, times); - _localcallstack.remove(_localcallstack.length-1); - } finally { - _lock.unlock(); - } - } - } - } - - def getOpNames(): Array[String] = { - _lock.lock(); - try { - return _timings.keys.toList.toArray; - } finally { - _lock.unlock(); - } - } - - def getStats(opname: String): Array[double] = { - _lock.lock(); - - try { - var times:ListBuffer[double] = _timings(opname); - var total = times.foldRight(0.0)(_ + _); - return Array(times.size, total, (total / times.size)); - } finally { - _lock.unlock(); - } - } - - def reset() { - _lock.lock(); - _timings = new HashMap[String,ListBuffer[double]]; - _lock.unlock(); - } -} |