fr.lifl.magique.policy.concurrency
Class RandomConcurrencyPolicy

java.lang.Object
  fr.lifl.magique.policy.concurrency.RandomConcurrencyPolicy

All Implemented Interfaces:

ConcurrencyPolicy

public class RandomConcurrencyPolicy

extends java.lang.Object

implements ConcurrencyPolicy

this is very a simple concurrency policy, answer is considered as being received as soon as minNumberOfAnswers answer has been received, the selected answer is randomly chosen

Constructor Summary

RandomConcurrencyPolicy(int minNumberOfAnswers)

Method Summary

boolean	isAnswerReceived(AnswerVector theAnswers) returns true if at least minNumberOfAnswers answers have been received
Answer	selectAnswer(AnswerVector theAnswers) select randomly an answer among those arrived

Methods inherited from class java.lang.Object

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

Constructor Detail

RandomConcurrencyPolicy

public RandomConcurrencyPolicy(int minNumberOfAnswers)

Method Detail

selectAnswer

public Answer selectAnswer(AnswerVector theAnswers)

select randomly an answer among those arrived

Specified by:

selectAnswer in interface ConcurrencyPolicy

Returns:

THE slected answer

See Also:

Answer

isAnswerReceived

public boolean isAnswerReceived(AnswerVector theAnswers)

returns true if at least minNumberOfAnswers answers have been received

Specified by:

isAnswerReceived in interface ConcurrencyPolicy

Returns:

true if at least one answer has been received

See Also:

Answer