Package org.matsim.core.replanning.modules

Classes
class	AbstractMultithreadedModule
class	ChangeLegMode
class	ChangeSingleLegMode
class	ExceptionHandler
interface	GenericPlanStrategyModule
class	KeepLastExecuted
class	ModeAndRouteConsistencyChecker
class	PlanAlgoThread
class	ReRoute
class	SubtourModeChoice
class	TripsToLegsModule

Functions
final void	prepareReplanning (ReplanningContext replanningContextTmp)
final ReplanningContext	getReplanningContext ()
final void	handlePlan (final Plan plan)
void	beforeFinishReplanningHook ()
void	afterFinishReplanningHook ()
final void	finishReplanning ()
void	initThreads ()

Function Documentation

prepareReplanning()

final void org.matsim.core.replanning.modules.prepareReplanning

(

ReplanningContext

replanningContextTmp

)

Definition at line 101 of file AbstractMultithreadedModule.java.

References org.matsim.core.replanning.modules.AbstractMultithreadedModule.directAlgo, org.matsim.core.replanning.modules.AbstractMultithreadedModule.getPlanAlgoInstance(), org.matsim.core.replanning.modules.initThreads(), org.matsim.core.replanning.modules.AbstractMultithreadedModule.numOfThreads, and org.matsim.core.replanning.modules.AbstractMultithreadedModule.replanningContext.

                                                                                {
        this.beforePrepareReplanningHook(replanningContextTmp);
        this.replanningContext = replanningContextTmp;
        if (this.numOfThreads == 0) {
            // it seems, no threads are desired :(
            this.directAlgo = getPlanAlgoInstance();
        } else {
            initThreads();
        }
        this.afterPrepareReplanningHook(replanningContextTmp);
    }

Here is the call graph for this function:

getReplanningContext()

final ReplanningContext org.matsim.core.replanning.modules.getReplanningContext ( )

protected

Definition at line 113 of file AbstractMultithreadedModule.java.

References org.matsim.core.replanning.modules.AbstractMultithreadedModule.replanningContext.

                                                             {
        return replanningContext;
    }

handlePlan()

final void org.matsim.core.replanning.modules.handlePlan

(

final Plan

plan

)

Definition at line 118 of file AbstractMultithreadedModule.java.

References org.matsim.core.replanning.modules.PlanAlgoThread.addPlanToThread(), org.matsim.core.replanning.modules.AbstractMultithreadedModule.algothreads, org.matsim.core.replanning.modules.AbstractMultithreadedModule.count, org.matsim.core.replanning.modules.AbstractMultithreadedModule.directAlgo, org.matsim.core.replanning.modules.AbstractMultithreadedModule.numOfThreads, and org.matsim.core.population.algorithms.PlanAlgorithm.run().

                                                  {
        if (this.directAlgo == null) {
            this.algothreads[this.count % this.numOfThreads].addPlanToThread(plan);
            this.count++;
        } else {
            this.directAlgo.run(plan);
        }
    }

Here is the call graph for this function:

beforeFinishReplanningHook()

void org.matsim.core.replanning.modules.beforeFinishReplanningHook ( )

protected

Definition at line 127 of file AbstractMultithreadedModule.java.

Referenced by org.matsim.core.replanning.modules.finishReplanning().

                                                {
        // left empty for inheritance
    }

afterFinishReplanningHook()

void org.matsim.core.replanning.modules.afterFinishReplanningHook ( )

protected

Definition at line 130 of file AbstractMultithreadedModule.java.

                                               {
        // left empty for inheritance
    }

finishReplanning()

final void org.matsim.core.replanning.modules.finishReplanning

(

)

Definition at line 135 of file AbstractMultithreadedModule.java.

References org.matsim.core.replanning.modules.beforeFinishReplanningHook(), org.matsim.core.replanning.modules.AbstractMultithreadedModule.directAlgo, org.matsim.core.replanning.modules.AbstractMultithreadedModule.log, org.matsim.core.replanning.modules.AbstractMultithreadedModule.name, and org.matsim.core.replanning.modules.AbstractMultithreadedModule.threads.

                                         {
        this.beforeFinishReplanningHook();
        
        if (this.directAlgo == null) {
            // only try to start threads if we did not directly work on all the plans
            log.info("[" + this.name + "] starting " + this.threads.length + " threads, handling " + this.count + " plans");

            // start threads
            for (Thread thread : this.threads) {
                thread.start();
            }

            // wait until each thread is finished
            try {
                for (Thread thread : this.threads) {
                    thread.join();
                }
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            log.info("[" + this.name + "] all " + this.threads.length + " threads finished.");
            Throwable throwable = this.hadException.get();
            if (throwable != null) {
                throw new RuntimeException("Some threads crashed, thus not all plans may have been handled.", throwable);
            }
        }
        // reset
        this.algothreads = null;
        this.threads = null;
        this.replanningContext = null;
        this.count = 0;
        
        this.afterFinishReplanningHook();
    }

Here is the call graph for this function:

initThreads()

void org.matsim.core.replanning.modules.initThreads ( )

private

Definition at line 170 of file AbstractMultithreadedModule.java.

References org.matsim.core.replanning.modules.AbstractMultithreadedModule.threads.

Referenced by org.matsim.core.replanning.modules.prepareReplanning().

                               {
        if (this.threads != null) {
            throw new RuntimeException("threads are already initialized");
        }

        this.hadException.set(null);
        this.threads = new Thread[this.numOfThreads];
        this.algothreads = new PlanAlgoThread[this.numOfThreads];

        Counter counter = null;
        // setup threads
        for (int i = 0; i < this.numOfThreads; i++) {
            PlanAlgorithm algo = getPlanAlgoInstance();
            if (i == 0) {
                this.name = algo.getClass().getSimpleName();
                counter = new Counter("[" + this.name + "] handled plan # ");
            }
            PlanAlgoThread algothread = new PlanAlgoThread(algo, counter);
            Thread thread = new Thread(algothread, this.name + "." + i);
            thread.setUncaughtExceptionHandler(this.exceptionHandler);
            this.threads[i] = thread;
            this.algothreads[i] = algothread;
        }
    }