org.encog.neural.networks.training.concurrent
public final class ConcurrentTrainingManager extends Object implements Runnable
Modifier and Type | Method and Description |
---|---|
void |
addPerformer(ConcurrentTrainingPerformer performer)
Add a performer.
|
void |
addTrainingJob(TrainingJob job)
Add a training job.
|
void |
clearPerformers()
Clear all of the performers.
|
void |
clearQueue()
Clear the workload.
|
void |
detectPerformers()
Detect performers.
|
void |
detectPerformers(boolean splitCores)
Detect performers.
|
static ConcurrentTrainingManager |
getInstance() |
boolean |
isSingleThreaded() |
void |
jobDone(long time,
ConcurrentTrainingPerformerCPU perf)
Wait for job to finish.
|
void |
join()
Wait for all tasks to finish.
|
void |
run()
Perform the training.
|
void |
setReport(StatusReportable report)
Setup the object to report status to.
|
void |
setSingleThreaded(boolean singleThreaded) |
void |
start()
Start the manager.
|
String |
toString() |
ConcurrentTrainingPerformer |
waitForFreePerformer()
Wait for a free performer.
|
public static ConcurrentTrainingManager getInstance()
public void addPerformer(ConcurrentTrainingPerformer performer)
performer
- The performer to add.public void addTrainingJob(TrainingJob job)
job
- The training job to add.public void clearPerformers()
public void clearQueue()
public void detectPerformers()
public void detectPerformers(boolean splitCores)
splitCores
- True, if a CPU performer should be created for each core.public boolean isSingleThreaded()
public void jobDone(long time, ConcurrentTrainingPerformerCPU perf)
time
- The time to wait.perf
- The performer.public void join()
public void setReport(StatusReportable report)
report
- The object to report status to.public void setSingleThreaded(boolean singleThreaded)
public void start()
public ConcurrentTrainingPerformer waitForFreePerformer()
Copyright © 2014. All Rights Reserved.