source: tmcsimulator/trunk/test/tmcsim/client/cadclientgui/data/CADDataConcurrencyTest.java @ 476

package tmcsim.client.cadclientgui.data;

import java.util.ArrayList;
import java.util.Vector;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.table.DefaultTableModel;
import junit.framework.TestCase;
import static junit.framework.TestCase.assertTrue;

/**
 * Test of CADData tableForUnitStatus()
 * @author jdalbey
 */
public class CADDataConcurrencyTest extends TestCase {
    private Vector<Unit> units;
    private Unit alpha;
    public CADDataConcurrencyTest(String testName) {
        super(testName);
    }
    
    @Override
    protected void setUp() throws Exception {
        super.setUp();
        units = new Vector<Unit>();
        alpha = new Unit("14-1");
        units.add(alpha);
        units.add(new Unit("14-2"));
        units.add(new Unit("14-3"));
        units.add(new Unit("14-4"));
        units.add(new Unit("14-5"));
    }
    
    @Override
    protected void tearDown() throws Exception {
        super.tearDown();
        System.out.println("Tearing down");
        try
        {
            Thread.sleep(100);
        }
        catch(InterruptedException e)
        { ; }        
    }

 
    public void testThreads()
    {
        System.out.println("Testing tableForUnitStatus()");
        CADData caddata = new CADData();
        caddata.setUnitsFromXML(units); // add 5 units
        caddata.addIncident(new Incident(101,"Desc", 10L));
        String unitNum = "14-1";
        caddata.unitAssignedToIncident(unitNum, 101, true);
        caddata.unitAvailable(unitNum);
        Threadserve ts1=new Threadserve(caddata, "A");
        Threadserve ts2=new Threadserve(caddata, "B");
        Threadserve ts3=new Threadserve(caddata, "C");
        DefaultTableModel m = caddata.tableForUnitStatus();
        assertEquals("main Incorrect Row Count:",5,m.getRowCount());
    }

    class Threadserve implements Runnable
    {
        private CADData caddata;
        private String id;
        private Thread th;
        Threadserve(CADData caddata, String id)
        {
            this.caddata = caddata;
            this.id = id;
            th=new Thread(this);
            th.start();
        }
        public void run()
        {       
          //System.out.println("Start "+ id);
          DefaultTableModel m = caddata.tableForUnitStatus();
          int loopLimit = m.getRowCount();
          assertEquals(id + " Incorrect Row Count:"+loopLimit,5,loopLimit);
        }
    }    
}