edu.pm

Class CommunityComputingServer

java.lang.Object

edu.pm.CommunityComputingServer

public class CommunityComputingServer
extends java.lang.Object

Реализация интерфейса CommunityComputingServerInterface.

Constructor Summary

Constructors

Constructor and Description
CommunityComputingServer(java.lang.Class<?> communityClass, int numIterations, long progressPeriod, java.util.concurrent.TimeUnit timeUnit) Создать экземпляр сервера.

Method Summary

Methods

Modifier and Type	Method and Description
void	addDataHandler(DataHandler dataHandler) Добавить обработчик данных.
Community	createCommunity() Создать новое сообщество.
long	getProgressPeriod()
java.lang.String	getState()
int	nextIter(int nodeId)
void	processException(int nodeId, java.lang.Exception e) Обработать исключительную ситуацию, возникшую на данном вычислительном узле.
void	processResult(int iter, int observerId, java.io.Serializable result) Обработать результат вычислений.
void	progress(int nodeId, int iter, double progress, long numRandoms) Сообщить серверу о том, что вычисление итерации завершено.
int	registerNode() Зарегистрировать новый вычислительный узел.
void	startComputing(int numThreads) Вычислить все итерации, которые предлагает этот сервер.
void	startServer() Опубликовать этот сервер в реестре удалённых объектов.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CommunityComputingServer

public CommunityComputingServer(java.lang.Class<?> communityClass,
                        int numIterations,
                        long progressPeriod,
                        java.util.concurrent.TimeUnit timeUnit)
                         throws PmException

Создать экземпляр сервера.

Parameters:

communityClass - класс сообщества.

numIterations - количество итераций, которые требуется посчитать.

progressPeriod - периодичность вызова метода progress(int, int, double, long) вычислителями (ms).

timeUnit - единица измерения времени для параметра progressPeriod.

Throws:

PmException - если communityClass не является наследником от Community или не имеет конструктора по умолчанию.

Method Detail

registerNode

public final int registerNode()

Зарегистрировать новый вычислительный узел.

Returns:

уникальный идентификатор нового вычислительного узла.

getProgressPeriod

public long getProgressPeriod()

Returns:

периодичность вызова метода CommunityComputingServerInterface.progress(int, int, double, long) вычислителями (ms).

nextIter

public final int nextIter(int nodeId)

Parameters:

nodeId - идентификатор вычислительного узла.

Returns:

номер очередной итерации или -1, если вычисления завершены.

progress

public final void progress(int nodeId,
            int iter,
            double progress,
            long numRandoms)

Сообщить серверу о том, что вычисление итерации завершено.

Parameters:

nodeId - идентификатор вычислительного узла.

iter - номер итерации.

progress - прогресс для данной итерации: отношение прошедшего времени в модели к общему времени моделирования, если прогресс больше или равен 1.0, то считается, что итерация завершена.

numRandoms - число использованных случайных чисел.

getState

public java.lang.String getState()

Returns:

строка с описанием прогресса вычислений.

createCommunity

public Community createCommunity()
                          throws PmException

Создать новое сообщество.

Returns:

созданное сообщество.

Throws:

PmException - если не удалось создать сообщество.

processResult

public void processResult(int iter,
                 int observerId,
                 java.io.Serializable result)

Обработать результат вычислений.

Parameters:

iter - номер итерации.

observerId - номер наблюдателя.

result - результат наблюдений за итерацией.

processException

public void processException(int nodeId,
                    java.lang.Exception e)

Обработать исключительную ситуацию, возникшую на данном вычислительном узле.

Parameters:

nodeId - идентификатор вычислительного узла.

e - исключительная ситуация.

addDataHandler

public void addDataHandler(DataHandler dataHandler)

Добавить обработчик данных.

Parameters:

dataHandler - обработчик данных.

startServer

public void startServer()
                 throws java.rmi.RemoteException,
                        java.rmi.AlreadyBoundException

Опубликовать этот сервер в реестре удалённых объектов.

Throws:

java.rmi.RemoteException - если не удалось получить реестр удалённых объектов.

java.rmi.AlreadyBoundException - если имя объекта в реестре уже занято.

startComputing

public void startComputing(int numThreads)

Вычислить все итерации, которые предлагает этот сервер.

Parameters:

numThreads - число вычислительных потоков; если numThreads <= 0, то число вычислительных потоков устанавливается равным числу доступных вычислительных ядер.