plham.main

Class ParallelRunnerProto<B>

plham.main.Runner<B>

plham.main.ParallelRunnerProto<B>

public class ParallelRunnerProto<B>
extends Runner<B>

Declaration: ParallelRunnerProto[B]{B haszero, B isref, B <: plham.main.Simulator} extends plham.main.Runner[B].

A Runner class for parallel execution. This is currently a prototype implementation, under development.

Field Summary

Fields

Modifier and Type	Field and Description
Fun_0_0 <B>	creator Field Type: ()=>B
PlaceLocalHandle<B>	plhE

Fields inherited from class plham.main.Runner

_PROFILE, useTeam

Constructor Summary

Constructors

Constructor and Description
ParallelRunnerProto(Fun_0_0 <B> creator) Declaration: this(creator:()=>B):plham.main.ParallelRunnerProto[B].

Method Summary

Modifier and Type	Method and Description
List<List<Order>>	collectOrders(Boolean diffPass)
void	distributeHifreqAgents(List<Agent> agents)
void	distributeInitialAgents(List<Agent> agents)
void	distributeInitialMarkets(List<Market> markets)
void	distributeLocalAgents(List<Agent> agents)
void	setupEnv(List<Market> markets, List<Agent> agents)
void	updateAgents()
void	updateMarkets(Long maxNormalOrders, Long maxHifreqOrders, Boolean diffPass)

Methods inherited from class plham.main.Runner

env, handleOrders, iterateMarketUpdates, run, setupEnv, updateAgents, updateMarkets

Field Detail

plhE

public PlaceLocalHandle<B> plhE

creator

public Fun_0_0 <B> creator

Field Type: ()=>B

Constructor Detail

ParallelRunnerProto

public ParallelRunnerProto(Fun_0_0 <B> creator)

Declaration: this(creator:()=>B):plham.main.ParallelRunnerProto[B].

Method Detail

updateMarkets

public void updateMarkets(Long maxNormalOrders,
                          Long maxHifreqOrders,
                          Boolean diffPass)

collectOrders

public List<List<Order>> collectOrders(Boolean diffPass)

distributeInitialMarkets

public void distributeInitialMarkets(List<Market> markets)

distributeInitialAgents

public void distributeInitialAgents(List<Agent> agents)

distributeLocalAgents

public void distributeLocalAgents(List<Agent> agents)

distributeHifreqAgents

public void distributeHifreqAgents(List<Agent> agents)

updateAgents

public void updateAgents()

setupEnv

public void setupEnv(List<Market> markets,
                     List<Agent> agents)