org.objectweb.proactive.calcium
Class Skernel

java.lang.Object
  org.objectweb.proactive.calcium.Skernel

Type Parameters:

T -

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

ActiveObjectSkernel

public class Skernel
extends java.lang.Object
implements java.io.Serializable

This class represents the skeleton kernel. It handles the tasks that must be solved, which can be in one of the following states: ready, waiting, processing, results(finished). Data parallelism is represented as child tasks of a parent task. This class handles the proper enqueing of tasks (child or parent).

Author:

The ProActive Team (mleyton)

See Also:

Serialized Form

Constructor Summary

Skernel()

Method Summary

int	getReadyQueueLength()
Task<?>	getReadyTask(long timeout) This method is gets a task ready for execution.
Task<?>	getResult()
StatsGlobalImpl	getStatsGlobal()
boolean	hasReadyTask()
boolean	hasResults()
boolean	isPaniqued()
void	putTask(Task<?> task)

Methods inherited from class java.lang.Object

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

Constructor Detail

Skernel

public Skernel()

Method Detail

getResult

public Task<?> getResult()
                  throws PanicException

Throws:

PanicException

getReadyTask

public Task<?> getReadyTask(long timeout)

This method is gets a task ready for execution. If there are no ready tasks, then this method can do two things: 1. Block until a ready task is available (only if there are taks being processed). 2. Return null if no tasks are available.

Parameters:

timeout - specifies the number of milliseconds to wait for a task. If the timeout is smaller or equal to cero, then it waits indefenetly.

Returns:

A task ready for execution or null.

putTask

public void putTask(Task<?> task)

isPaniqued

public boolean isPaniqued()

hasResults

public boolean hasResults()

hasReadyTask

public boolean hasReadyTask()

getReadyQueueLength

public int getReadyQueueLength()

getStatsGlobal

public StatsGlobalImpl getStatsGlobal()