@Test public void testTellThreadsToStop() { System.out.println("tellThreadsToStop"); AbstractSimpleThreadGroup instance = new AbstractSimpleThreadGroupImpl(); instance.tellThreadsToStop(); }
@Override public void tellThreadsToStop() { running = false; for (Entry<JMeterThread, Thread> entry : allThreads.entrySet()) { JMeterThread item = entry.getKey(); item.stop(); item.interrupt(); Thread t = entry.getValue(); if (t != null) { t.interrupt(); } } }
AbstractSimpleThreadGroup extends AbstractThreadGroup { @Override public void tellThreadsToStop() { running = false; for (Entry<JMeterThread, Thread> entry : allThreads.entrySet()) { JMeterThread item = entry.getKey(); item.stop(); item.interrupt(); Thread t = entry.getValue(); if (t != null) { t.interrupt(); } } } }
AbstractSimpleThreadGroup extends AbstractThreadGroup { @Override public void tellThreadsToStop() { running = false; for (Entry<JMeterThread, Thread> entry : allThreads.entrySet()) { JMeterThread item = entry.getKey(); item.stop(); item.interrupt(); Thread t = entry.getValue(); if (t != null) { t.interrupt(); } } } AbstractSimpleThreadGroup(); }
AbstractSimpleThreadGroup extends AbstractThreadGroup { @Override public void tellThreadsToStop() { running = false; for (Entry<JMeterThread, Thread> entry : allThreads.entrySet()) { JMeterThread item = entry.getKey(); item.stop(); item.interrupt(); Thread t = entry.getValue(); if (t != null) { t.interrupt(); } } } AbstractSimpleThreadGroup(); void scheduleThread(JMeterThread thread); @Override void start(int groupNum, ListenerNotifier notifier, ListedHashTree threadGroupTree, StandardJMeterEngine engine); @Override boolean stopThread(String threadName, boolean now); @Override void threadFinished(JMeterThread thread); @Override void tellThreadsToStop(); @Override void stop(); @Override int numberOfActiveThreads(); @Override boolean verifyThreadsStopped(); @Override void waitThreadsStopped(); }
AbstractSimpleThreadGroup extends AbstractThreadGroup { @Override public void tellThreadsToStop() { running = false; for (Entry<JMeterThread, Thread> entry : allThreads.entrySet()) { JMeterThread item = entry.getKey(); item.stop(); item.interrupt(); Thread t = entry.getValue(); if (t != null) { t.interrupt(); } } } AbstractSimpleThreadGroup(); void scheduleThread(JMeterThread thread); @Override void start(int groupNum, ListenerNotifier notifier, ListedHashTree threadGroupTree, StandardJMeterEngine engine); @Override boolean stopThread(String threadName, boolean now); @Override void threadFinished(JMeterThread thread); @Override void tellThreadsToStop(); @Override void stop(); @Override int numberOfActiveThreads(); @Override boolean verifyThreadsStopped(); @Override void waitThreadsStopped(); static final String THREAD_GROUP_DISTRIBUTED_PREFIX_PROPERTY_NAME; }