pegasus.mapreduce.common.coordination

Interface Barrier

All Known Implementing Classes:

MutexBarrier, SemaphoreBarrier

public interface Barrier

Method Summary

Modifier and Type	Method and Description
void	cleanup() Cleanups this barrier.
void	markCompleted() Marks this barrier completed.
void	setup() Initializes the barrier.
void	waitBarrier() Waits until this barrier is marked as completed.

Method Detail

setup

void setup()

Initializes the barrier.

markCompleted

void markCompleted()

Marks this barrier completed.

waitBarrier

void waitBarrier()

Waits until this barrier is marked as completed.

cleanup

void cleanup()

Cleanups this barrier.