Synchronizing Two Model Using Ptolemy II

1.right click on the PythonActor, choose “Customize”>> “Rename”

figure12

# This is a simple actor that copies the input to the output.
# You can remove the ports, add new ports, and modify the script.
#import the python model script, in the before,we has described how to add your .py file
#directory which is in the Ptolemy root directory to the jython classpath
from model import Model
# import message type from Ptolemy lib
import ptolemy.data.StringToken as StringToken
class Main :
"Copy the inputs to the output."
def __init__(self):
self.model=Model() #initialize the model
def fire(self) : # each signal will trigger the fire method of the actor.
for i in range(self.signal.getWidth()):
if self.signal.hasToken(i):
token = self.signal.get(i) #retrieve the signal
self.model.step() #model does step action
msg=self.model.getMsg() #get msg from the model inner,
if msg != "no_msg": #get msg from the model inner,
self.outctl.send(0,StringToken(msg))
for i in range(self.inctl.getWidth()):
if self.inctl.hasToken(i):
token=self.inctl.get(i) # retrieve the msg from other actor,
msg=token.stringValue()
self.model.doAct(msg) # invoke the functiono or method in model by sending msg to it

package test;

import java.io.*;
import java.util.Iterator;
import repast.simphony.batch.BatchScenarioLoader;
import repast.simphony.context.Context;
import repast.simphony.engine.controller.Controller;
import repast.simphony.engine.controller.DefaultController;
import repast.simphony.engine.environment.AbstractRunner;
import repast.simphony.engine.environment.ControllerRegistry;
import repast.simphony.engine.environment.DefaultRunEnvironmentBuilder;
import repast.simphony.engine.environment.RunEnvironment;
import repast.simphony.engine.environment.RunEnvironmentBuilder;
import repast.simphony.engine.environment.RunState;
import repast.simphony.engine.schedule.ISchedule;
import repast.simphony.engine.schedule.Schedule;
import repast.simphony.parameter.SweeperProducer;
import simphony.util.messages.MessageCenter;
import sampletest.SampleAgent;

public class TestRunner extends AbstractRunner {

private static MessageCenter msgCenter = MessageCenter.getMessageCenter(TestRunner.class);

private RunEnvironmentBuilder runEnvironmentBuilder;
protected Controller controller;
protected boolean pause = false;
protected Object monitor = new Object();
protected SweeperProducer producer;
private ISchedule schedule;
private Context context;

public TestRunner() {
runEnvironmentBuilder = new DefaultRunEnvironmentBuilder(this, true);
controller = new DefaultController(runEnvironmentBuilder);
controller.setScheduleRunner(this);
}

public void load(File scenarioDir) throws Exception{
if (scenarioDir.exists()) {
BatchScenarioLoader loader = new BatchScenarioLoader(scenarioDir);
ControllerRegistry registry = loader.load(runEnvironmentBuilder);
controller.setControllerRegistry(registry);

} else {
msgCenter.error("Scenario not found", new IllegalArgumentException(
"Invalid scenario " + scenarioDir.getAbsolutePath()));
return;
}

controller.batchInitialize();
controller.runParameterSetters(null);
}

public void runInitialize(){
controller.runInitialize(null);
RunState rs=RunState.getInstance();
schedule = rs.getScheduleRegistry().getModelSchedule(); //get the schedule
context = (Context)rs.getMasterContext(); //get the main context of the model
}

public void cleanUpRun(){
controller.runCleanup();
}
public void cleanUpBatch(){
controller.batchCleanup();
}

// returns the tick count of the next scheduled item
public double getNextScheduledTime(){
return ((Schedule)RunEnvironment.getInstance().getCurrentSchedule()).peekNextAction().getNextTime();
}

// returns the number of model actions on the schedule
public int getModelActionCount(){
return schedule.getModelActionCount();
}

// returns the number of non-model actions on the schedule
public int getActionCount(){
return schedule.getActionCount();
}

// Step the schedule
public void step(){
schedule.execute();
}

// stop the schedule
public void stop(){
if ( schedule != null )
schedule.executeEndActions();
}

public void setFinishing(boolean fin){
schedule.setFinishing(fin);
}

public void execute(RunState toExecuteOn) {
// required AbstractRunner stub. We will control the
// schedule directly.
}
public Iterator getAgentIterator(){ //get the collection of the agents
Iterator it=context.getObjects(SampleAgent.class).iterator();
return it;
}
public static void main(String[] args){
System.err.println(new TestRunner().getModelActionCount());
}
}

public class TestMain {
private TestRunner runner;
private int count=1;
private FileTest ft;
public TestMain(){
runner=new TestRunner();
ft=new FileTest("simphony.txt");
}
public void initialize(){ //initialize method
File file = new File("Sample_Test\\sampletest.rs");// repast scenario file directory
try {
runner.load(file); // load the repast scenario
} catch (Exception e) {
e.printStackTrace();
}
runner.runInitialize();
}

public void pushMsgToAgent(String msg){ //send messages to agents
Iterator it=runner.getAgentIterator();
while(it.hasNext()){
SampleAgent sa=(SampleAgent)it.next();
sa.doAction(msg);
}
}

public String getMsgFromAgents(){ //get the messages from the simphony model
String msg="no_msg";
if(count%5==0){
RandNum randNum=new RandNum();
Date date=new Date();
int action=randNum.getRandNumber();
if(action==1){
msg = "add";
}
else if(action==2){
msg = "minus";
}
else{
msg = "nothing";
}
ft.writeStr(date+" "+String.format("%16s","send msg "+msg));
}

return msg;
}
public void runStep(){ //step running method
System.err.print(runner.getActionCount());
count++;
runner.step();// execute all scheduled actions at next tick
}
public void endRunner(){ //stop the model method
runner.stop();
runner.cleanUpRun();
runner.cleanUpBatch();
}
}

# This is a simple actor that copies the input to the output.
# You can remove the ports, add new ports, and modify the script.
#import the TestMain Adapter class,
#This class is as an intermediate that can initialize the simphony model and it control its actions.
import test.TestMain as TestMain
# import message type from Ptolemy lib
import ptolemy.data.StringToken as StringToken
class Main :
"Copy the inputs to the output."
def __init__(self):
self.testmain=TestMain()
self.testmain.initialize() # initialize the simphony model
def fire(self) : # each signal will trigger the fire method of the actor.
for i in range(self.signal.getWidth()):
if self.signal.hasToken(i):
token = self.signal.get(i) # retrieve the signal
self.testmain.runStep() # model does step action
ctl=self.testmain.getMsgFromAgents() # get msg from the model inner,
if ctl != "no_msg": # decide whether to send msg out
self.outctl.send(0,StringToken(ctl))
for i in range(self.inctl.getWidth()):
if self.inctl.hasToken(i):
token = self.inctl.get(i)
msg=token.stringValue() # retrieve the msg from other actor,
self.testmain.pushMsgToAgent(msg) # invoke the method in model by sending msg to it