CANT23.java

//This can either run as an applet in which case init is used
//or as an application, in which case main is used.  The environment
//it runs from chooses (java debugger application web browser=applet)
//In Kawa 16/10/02

import java.io.*;
import java.util.*;
import java.applet.*;
import java.net.*;  //for URL


public class CANT23 extends Applet{

  public static String ExperimentXMLFile = "Param.xml";
  public static CANTNet nullNet;
  public static Hashtable nets;
  public static boolean isRunning=false;
  public static int CANTStep = 0;
  public static int delayBetweenSteps = 20;
  public static CANTExperiment experiment;
  public static CANT23.WorkerThread workerThread;

  public static void setRunning(boolean status) {isRunning = status;}

  public static boolean isRandomInitialised = false;
    //public static long seed=78266;//set your own seed
  public static long seed = (long) (Math.random()*64000000); // set random seed
  public static Random random;// use a random object instead of Math.random()

  public static void main(String args[]){
System.out.println("Start CANT ");
    initRandom();
    makeNewSystem();
  }

  protected static void initRandom() {
    if (!isRandomInitialised) {
      isRandomInitialised = true;
      random = new Random(seed);
      System.err.println("Seed: " + seed);
    }
    else 
      random = new Random();
  }

  protected static void makeNewSystem() {
    nullNet = new CANTNet();
    nets = NetManager.readNets(ExperimentXMLFile,nullNet);
    workerThread = new CANT23.WorkerThread();
    initializeExperiment();
    workerThread.start();	
  }
  
  protected static void closeSystem() {
    Enumeration eNum = nets.elements();
	CANTNet net;

    do	{
      net = (CANTNet)eNum.nextElement();
      net.cantFrame.dispose();
	}
    while (eNum.hasMoreElements());
	
    CANTStep=0;  
  }
  
  public static void saveAllNets() {
    System.out.println("save all nets");
  
    Enumeration eNum = nets.elements();
    while (eNum.hasMoreElements()) {
      CANTNet net = (CANTNet)eNum.nextElement();
      net.write();
    }
  }
  
  //set up the experiment specific parameters.
  private static void initializeExperiment() {
System.out.println("initialize Experiment ");
  
    experiment = new CANTExperiment();  
    experiment.printExpName();
  }

  //run one step of the simulation.
  public static synchronized void runOneStep() {
//System.out.println("CANT run one step");
    if (experiment.trainingLength == CANTStep) experiment.switchToTest();
    if (experiment.getInTest()) experiment.measure(CANTStep);
	
	if (experiment.isEndEpoch(CANTStep))
	   experiment.endEpoch();

    Enumeration eNum = nets.elements();
    while (eNum.hasMoreElements()) {
      CANTNet net = (CANTNet)eNum.nextElement();
      net.runOneStep(CANTStep);
    }
    CANTStep++;
    //System.out.println("Incremenet cantstep"+CANTStep);

	if (experiment.experimentDone(CANTStep)) 
	  {
        System.out.println("experiment Done"+CANTStep);
        closeSystem();
		makeNewSystem();
	  }
  }


/*
    public static void setConnectionToOther(CANTNet fromNet, int fromNeuronID, double weight,
                                                  String toNetName, int toNeuronID) {
       CANTNet toNet;
       toNet = (CANTNet)nets.get(toNetName);
       fromNet.setConnectionToOther(fromNeuronID, weight, toNet, toNeuronID);
    }
    public static void reconnectFromOtherNets(CANTNet newNet) {
            String toNetName = newNet.getName();
            Enumeration enum = nets.elements();
            while (enum.hasMoreElements()) {
              CANTNet net =(CANTNet)enum.nextElement();
              if (!net.getName().equals(toNetName) )
                newNet.resetConnectionsFromOther(net);
            }
    }
*/

  //embedded Thread class
  public static class WorkerThread extends Thread{
    public void run(){
      //System.out.println("Thread ");
      while(true){
         if(isRunning){
           runOneStep();
         }
         else{
           try{sleep(delayBetweenSteps);}
		   catch(InterruptedException ie){ie.printStackTrace();}
             }//else
       }//while
    }//run
  }//WorkerThread class
}