2 * Copyright (C) 2015, EfficiOS Inc., Alexandre Montplaisir <alexmonthy@efficios.com>
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation; either version 2 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License along
15 * with this program; if not, write to the Free Software Foundation, Inc.,
16 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
19 package org
.lttng
.ust
.agent
.benchmarks
.jul
.handler
;
21 import java
.util
.LinkedList
;
22 import java
.util
.List
;
23 import java
.util
.logging
.Handler
;
24 import java
.util
.logging
.Level
;
25 import java
.util
.logging
.Logger
;
27 import org
.junit
.After
;
28 import org
.junit
.Before
;
29 import org
.junit
.Test
;
31 public abstract class JulHandlerBenchmarkBase
{
33 // ------------------------------------------------------------------------
34 // Configurable test parameters
35 // ------------------------------------------------------------------------
37 /** Nb of runs per test, result will be averaged */
38 private static final int NB_RUNS
= 10;
40 /** Trace/log events per run */
41 private static final int NB_ITER
= 100000;
43 /** Which tests to run (for different number of threads) */
44 private static final int[] NB_THREADS
= {1, 1, 2, 3, 4, 5, 6, 7, 8};
46 // ------------------------------------------------------------------------
48 // ------------------------------------------------------------------------
50 protected Logger logger
;
51 protected Handler handler
;
53 // ------------------------------------------------------------------------
54 // Maintenance methods
55 // ------------------------------------------------------------------------
59 /* Set up the logger */
60 logger
= Logger
.getLogger("Test logger");
61 logger
.setUseParentHandlers(false);
62 logger
.setLevel(Level
.ALL
);
64 /* Sub-classes' @Before will setup the Handler */
68 public void teardown() {
69 if (handler
!= null) {
70 logger
.removeHandler(handler
);
77 // ------------------------------------------------------------------------
79 // ------------------------------------------------------------------------
82 public void runBenchmark() {
83 if (handler
!= null) {
84 logger
.addHandler(handler
);
88 System
.out
.println("Running benchmark: " + this.getClass().getCanonicalName());
89 for (int i
: NB_THREADS
) {
94 private static void runTest(Logger log
, int nbThreads
) {
95 long start
, end
, average
, total
= 0;
96 for (int i
= 0; i
< NB_RUNS
; i
++) {
97 Runner runner
= new Runner(nbThreads
, NB_ITER
, log
);
99 start
= System
.nanoTime();
101 end
= System
.nanoTime();
103 total
+= (end
- start
);
105 average
= total
/ NB_RUNS
;
106 System
.out
.println(nbThreads
+ " threads, average = " + average
/ NB_ITER
+ " ns/event");
109 // ------------------------------------------------------------------------
111 // ------------------------------------------------------------------------
113 private static class Runner
implements Runnable
{
115 private final List
<Worker
> workers
= new LinkedList
<>();
116 private final List
<Thread
> workerThreads
= new LinkedList
<>();
118 public Runner(int nbThreads
, int nbIter
, Logger log
) {
120 for (int id
= 0; id
< nbThreads
; id
++) {
121 Worker curWorker
= new Worker(id
, nbIter
, log
);
122 workers
.add(curWorker
);
123 workerThreads
.add(new Thread(curWorker
, "worker " + id
));
129 for (Thread curThread
: workerThreads
) {
133 for (Thread curThread
: workerThreads
) {
136 } catch (InterruptedException e
) {
142 private static class Worker
implements Runnable
{
144 private final Logger log
;
145 private final int threadId
;
146 private final int nbIter
;
148 public Worker(int threadId
, int nbIter
, Logger log
) {
150 this.threadId
= threadId
;
151 this.nbIter
= nbIter
;
156 for (int i
= 0; i
< nbIter
; i
++) {
157 log
.info("Thread " + threadId
+ ", iteration " + i
);
This page took 0.0352 seconds and 5 git commands to generate.