Bug 1446: Add new concurrent classes for tracking stats 37/9837/7
authortpantelis <tpanteli@brocade.com>
Thu, 7 Aug 2014 21:32:09 +0000 (17:32 -0400)
committerTony Tkacik <ttkacik@cisco.com>
Fri, 29 Aug 2014 18:13:35 +0000 (20:13 +0200)
commit3e0931740202d83c5f5fbec4172cda20baae2594
treeaf0d1fbab5a0e8d8e52d2b51a5ebe2da550ad28c
parent08426cfd9d28adb465cf65194f93c58e477eceb4
Bug 1446: Add new concurrent classes for tracking stats

TrackingLinkedBlockingQueue
    A LinkedBlockingQueue that tracks the largest queue size foridebugging.

CountingRejectedExecutionHandler
    A RejectedExecutionHandler that delegates to a backing RejectedExecutionHandler
    and counts the number of rejected tasks.

DurationStatsTracker
    Class that calculates and tracks time duration statistics.

Change-Id: I1b7bbb45301d8cf682a5de5d51cc64727e3139dc
Signed-off-by: tpantelis <tpanteli@brocade.com>
13 files changed:
common/util/pom.xml
common/util/src/main/java/org/opendaylight/yangtools/util/DurationStatsTracker.java [new file with mode: 0644]
common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/CachedThreadPoolExecutor.java
common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/CountingRejectedExecutionHandler.java [new file with mode: 0644]
common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/FastThreadPoolExecutor.java
common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/ListenerNotificationQueueStats.java [new file with mode: 0644]
common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/QueuedNotificationManager.java
common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/SpecialExecutors.java
common/util/src/main/java/org/opendaylight/yangtools/util/concurrent/TrackingLinkedBlockingQueue.java [new file with mode: 0644]
common/util/src/test/java/org/opendaylight/yangtools/util/DurationStatsTrackerTest.java [new file with mode: 0644]
common/util/src/test/java/org/opendaylight/yangtools/util/concurrent/CountingRejectedExecutionHandlerTest.java [new file with mode: 0644]
common/util/src/test/java/org/opendaylight/yangtools/util/concurrent/ThreadPoolExecutorTest.java
common/util/src/test/java/org/opendaylight/yangtools/util/concurrent/TrackingLinkedBlockingQueueTest.java [new file with mode: 0644]