You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jmeter-dev@jakarta.apache.org by se...@apache.org on 2009/04/08 13:07:17 UTC
svn commit: r763182 -
/jakarta/jmeter/trunk/src/core/org/apache/jmeter/engine/StandardJMeterEngine.java
Author: sebb
Date: Wed Apr 8 11:07:17 2009
New Revision: 763182
URL: http://svn.apache.org/viewvc?rev=763182&view=rev
Log:
Add thread/sampler interrupt to stop now processing
Modified:
jakarta/jmeter/trunk/src/core/org/apache/jmeter/engine/StandardJMeterEngine.java
Modified: jakarta/jmeter/trunk/src/core/org/apache/jmeter/engine/StandardJMeterEngine.java
URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/core/org/apache/jmeter/engine/StandardJMeterEngine.java?rev=763182&r1=763181&r2=763182&view=diff
==============================================================================
--- jakarta/jmeter/trunk/src/core/org/apache/jmeter/engine/StandardJMeterEngine.java (original)
+++ jakarta/jmeter/trunk/src/core/org/apache/jmeter/engine/StandardJMeterEngine.java Wed Apr 8 11:07:17 2009
@@ -299,7 +299,7 @@
}
private class StopTest implements Runnable {
- boolean now;
+ final boolean now;
private StopTest() {
now = true;
@@ -507,10 +507,11 @@
Iterator iter = new HashSet(allThreads.keySet()).iterator();
while (iter.hasNext()) {
JMeterThread item = (JMeterThread) iter.next();
- item.stop();
+ item.stop(); // set stop flag
+ item.interrupt(); // interrupt sampler if possible
Thread t = (Thread) allThreads.get(item);
if (t != null) {
- t.interrupt();
+ t.interrupt(); // also interrupt JVM thread
} else {
log.warn("Lost thread: " + item.getThreadName());
allThreads.remove(item);
---------------------------------------------------------------------
To unsubscribe, e-mail: jmeter-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: jmeter-dev-help@jakarta.apache.org