org.apache.giraph.ooc

Class OutOfCoreIOScheduler

java.lang.Object

org.apache.giraph.ooc.OutOfCoreIOScheduler

public class OutOfCoreIOScheduler
extends Object

Representation of IO thread scheduler for out-of-core mechanism

Field Summary

Fields

Modifier and Type	Field and Description
static IntConfOption	OOC_WAIT_INTERVAL If an IO thread does not have any command to do, it waits for certain a period and check back again to see if there exist any command to perform.

Method Summary

Modifier and Type	Method and Description
void	addIOCommand(IOCommand ioCommand) Add an IO command to the scheduling queue of the IO scheduler
IOCommand	getNextIOCommand(int threadId) Generate and return the next appropriate IO command for a given thread
void	ioCommandCompleted(IOCommand command) Notify IO scheduler that the IO command is completed
void	shutdown() Shutdown/Terminate the IO scheduler, and notify all IO threads to halt

Methods inherited from class java.lang.Object

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

Field Detail

OOC_WAIT_INTERVAL

public static final IntConfOption OOC_WAIT_INTERVAL

If an IO thread does not have any command to do, it waits for certain a period and check back again to see if there exist any command to perform. This constant determines this wait period in milliseconds.

Method Detail

getNextIOCommand

public IOCommand getNextIOCommand(int threadId)

Generate and return the next appropriate IO command for a given thread

Parameters:

threadId - id of the thread ready to execute the next IO command

Returns:

next IO command to be executed by the given thread

ioCommandCompleted

public void ioCommandCompleted(IOCommand command)

Notify IO scheduler that the IO command is completed

Parameters:

command - completed command

addIOCommand

public void addIOCommand(IOCommand ioCommand)

Add an IO command to the scheduling queue of the IO scheduler

Parameters:

ioCommand - IO command to add to the scheduler

shutdown

public void shutdown()

Shutdown/Terminate the IO scheduler, and notify all IO threads to halt