You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jmeter.apache.org by pm...@apache.org on 2016/12/21 16:48:38 UTC
svn commit: r1775500 -
/jmeter/trunk/src/components/org/apache/jmeter/modifiers/SampleTimeout.java
Author: pmouawad
Date: Wed Dec 21 16:48:37 2016
New Revision: 1775500
URL: http://svn.apache.org/viewvc?rev=1775500&view=rev
Log:
Sonar : Fix code smells
Use Java8 lambda
Modified:
jmeter/trunk/src/components/org/apache/jmeter/modifiers/SampleTimeout.java
Modified: jmeter/trunk/src/components/org/apache/jmeter/modifiers/SampleTimeout.java
URL: http://svn.apache.org/viewvc/jmeter/trunk/src/components/org/apache/jmeter/modifiers/SampleTimeout.java?rev=1775500&r1=1775499&r2=1775500&view=diff
==============================================================================
--- jmeter/trunk/src/components/org/apache/jmeter/modifiers/SampleTimeout.java (original)
+++ jmeter/trunk/src/components/org/apache/jmeter/modifiers/SampleTimeout.java Wed Dec 21 16:48:37 2016
@@ -48,6 +48,12 @@ public class SampleTimeout extends Abstr
private static final String TIMEOUT = "InterruptTimer.timeout"; //$NON-NLS-1$
+ private ScheduledFuture<?> future;
+
+ private final transient ScheduledExecutorService execService;
+
+ private final boolean debug;
+
private static class TPOOLHolder {
private TPOOLHolder() {
// NOOP
@@ -65,12 +71,6 @@ public class SampleTimeout extends Abstr
return TPOOLHolder.EXEC_SERVICE;
}
- private ScheduledFuture<?> future;
-
- private final transient ScheduledExecutorService execService;
-
- private final boolean debug;
-
/**
* No-arg constructor.
*/
@@ -125,21 +125,18 @@ public class SampleTimeout extends Abstr
}
final Interruptible sampler = (Interruptible) samp;
- Callable<Object> call = new Callable<Object>() {
- @Override
- public Object call() throws Exception {
- long start = System.nanoTime();
- boolean interrupted = sampler.interrupt();
- String elapsed = Double.toString((double)(System.nanoTime()-start)/ 1000000000)+" secs";
- if (interrupted) {
- LOG.warn("Call Done interrupting " + getInfo(samp) + " took " + elapsed);
- } else {
- if (debug) {
- LOG.debug("Call Didn't interrupt: " + getInfo(samp) + " took " + elapsed);
- }
+ Callable<Object> call = () -> {
+ long start = System.nanoTime();
+ boolean interrupted = sampler.interrupt();
+ String elapsed = Double.toString((double)(System.nanoTime()-start)/ 1000000000)+" secs";
+ if (interrupted) {
+ LOG.warn("Call Done interrupting " + getInfo(samp) + " took " + elapsed);
+ } else {
+ if (debug) {
+ LOG.debug("Call Didn't interrupt: " + getInfo(samp) + " took " + elapsed);
}
- return null;
}
+ return null;
};
// schedule the interrupt to occur and save for possible cancellation
future = execService.schedule(call, timeout, TimeUnit.MILLISECONDS);