Producers concurrently add points to an amount of
* randomly shared ITrace2D instances.
*
* One Consumer invokes paint on the Chart2D thus
* allowing to drop pending changes stored in it.
*
*
* @author Achim Westermann
*
*/
public class TestMultiThreadingAndTracing extends TestMultithreading {
/**
* Runnable that will take a random break between 0 and
* sleepRange milliseconds and then consume added
* {@link TracePoint2D} (by {@link Producer}) by invoking
* {@link Chart2D#paint(java.awt.Graphics)}.
*
*
* @author Achim Westermann
*
* @version $Revision: 1.11 $
*/
class Consumer extends TestMultithreading.Consumer {
/** The maximum of milliseconds between two add operations. */
private long m_sleepRange;
/** Flag to allow stopping this Thread at a defined consitant code position. */
private boolean m_stop = false;
/**
* Creates an instance that will take a random break between 0 and
* sleepRange milliseconds between two add operations.
*
*
* @param sleepRange
* the maximum of milliseconds between two add operations.
*/
Consumer(final long sleepRange) {
super(sleepRange);
}
/**
* @see info.monitorenter.gui.chart.TestMultithreading.Consumer#run()
*/
@Override
public void run() {
MockGraphics2D mockGraphics = new MockGraphics2D();
while (!(this.m_stop || TestMultiThreadingAndTracing.this.isAllProducersFinished())) {
try {
Thread.sleep((long) (Math.random() * this.m_sleepRange));
} catch (InterruptedException e) {
e.printStackTrace();
this.m_stop = true;
}
System.out.println('[' + this.getClass().getName() + "] painting...");
TestMultiThreadingAndTracing.this.m_chart.paint(mockGraphics);
}
}
}
/**
* Producer implementation that sleeps a random range of milliseconds within
* {@link #PRODUCER_SLEEPRANGE} and then adds a newly created
* {@link TracePoint2D} to a random picked {@link ITrace2D}
* for {@link #PRODUCER_ADD_POINT_AMOUNT} times.
*
*/ class Producer extends TestMultithreading.Producer { /** The maximum of milliseconds between two add operations. */ private long m_sleepRange; /** Flag to stop the producer. */ private boolean m_stop = false; /** The amount to add. */ private long m_toAdd; /** *
* Constructs a producer that will add toAdd points with random
* breaks of milliseconds between maxSleep and zero.
*
{@link ITrace2D} class to use instances of for the test. */
protected static final Class< ? > TRACE_CLASS = Trace2DLtd.class;
// configuration
/** Amount of traces ( same as threads ) to concurrently paint on the chart. */
protected static final int TRACES_AMOUNT = 10;
/**
* Test suite for this test class.
*
*
* @return the test suite
*/
public static Test suite() {
TestSuite suite = new TestSuite();
suite.setName(TestMultiThreadingAndTracing.class.getName());
suite.addTest(new TestMultiThreadingAndTracing("testTrace2DLtd"));
return suite;
}
/** The traces of the concurrent threads to test. */
protected List
*
* @param testName
* the name of the test case.
*/
public TestMultiThreadingAndTracing(final String testName) {
super(testName);
}
/**
* Picks a random trace of the internal list of traces.
*
*
* @return a random trace of the internal list of traces.
*/
ITrace2D pickRandomTrace() {
int index = (int) Math.round(Math.random() * TestMultiThreadingAndTracing.TRACES_AMOUNT);
return this.m_traces.get(index);
}
// ////////////////////////////
// Worker classes
// ////////////////////////////
/**
* Writes a report to
*
* @see info.monitorenter.gui.chart.TestMultithreading#report()
*/
@Override
void report() {
long keys = this.m_weakMap.size();
System.out.println("Points remaining in the weakMap: " + keys);
System.out.println("System.runFinalization()... ");
System.runFinalization();
System.out.println("System.gc()... ");
System.gc();
keys = this.m_weakMap.size();
System.out.println("Points remaining in the weakMap: " + keys);
keys = 0;
for (ITracePoint2D point : this.m_weakMap.keySet()) {
keys++;
System.out.println("Point " + point.toString() + " was not dropped.");
}
System.out.println("Points remaining in the weakMap: " + keys);
Assert.assertFalse("There are " + keys
+ " TracePoint2D instances not deleted from the WeakHashMap.", keys > this.m_trace
.getMaxSize());
}
/**
* Creates producers, consumers, traces and other members for the test run.
*
*
* @see info.monitorenter.gui.chart.TestMultithreading#setUp()
*
* @throws Exception
* if something goes wrong.
*/
@Override
public void setUp() throws Exception {
this.m_trace = (ITrace2D) TestMultiThreadingAndTracing.TRACE_CLASS.newInstance();
this.m_chart = new Chart2D();
this.m_weakMap = new WeakHashMap
*
* @see info.monitorenter.gui.chart.TestMultithreading#tearDown()
*/
@Override
protected void tearDown() throws Exception {
super.tearDown();
this.m_traces = null;
}
}
{@link System#out}.
*