org.turro.queue.Tasks Class Reference

Inheritance diagram for org.turro.queue.Tasks:

Collaboration diagram for org.turro.queue.Tasks:

Public Member Functions
void	run ()

Static Public Member Functions
static void	execute ()
static void	add (Task task)
static TaskQueue	tasks ()
static boolean	isInterrupted ()

Detailed Description

Author

Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 29 of file Elephant/elephant/src/main/java/org/turro/queue/Tasks.java.

Member Function Documentation

add()

static void org.turro.queue.Tasks.add ( Task  task )

static

Definition at line 42 of file Elephant/elephant/src/main/java/org/turro/queue/Tasks.java.

                                    {
    Tasks tasks = getInstance();
    tasks.doAdd(task);
    tasks.doExecute();
  }

Here is the call graph for this function:

execute()

static void org.turro.queue.Tasks.execute ( )

static

Definition at line 38 of file Elephant/elephant/src/main/java/org/turro/queue/Tasks.java.

                               {
    getInstance().doExecute();
  }

Here is the caller graph for this function:

isInterrupted()

static boolean org.turro.queue.Tasks.isInterrupted ( )

static

Definition at line 52 of file Elephant/elephant/src/main/java/org/turro/queue/Tasks.java.

                                        {
    Thread t = getInstance().execution;
    return t == null || t.isInterrupted();
  }

Here is the caller graph for this function:

run()

void org.turro.queue.Tasks.run

(

)

Definition at line 86 of file Elephant/elephant/src/main/java/org/turro/queue/Tasks.java.

                    {
    Iterator<Task> tasks = queue.iterator();
    while(tasks.hasNext()) {
      Task task = tasks.next();
      if(task.getStatus().equals(TaskStatus.TASK_EXECUTING)) {
        break;
      } else if(task.getStatus().equals(TaskStatus.TASK_PENDING)) {
        task.execute();
        break;
      } else if(task.getStatus().equals(TaskStatus.TASK_FAILED)) {
        if(task.isReintent()) {
          task.execute();
          break;
        } else if(isOld(task)) {
          tasks.remove();
        }
      } else {
        if(isOld(task)) {
          tasks.remove();
        }
      }
    }
  }

Here is the call graph for this function:

tasks()

static TaskQueue org.turro.queue.Tasks.tasks ( )

static

Definition at line 48 of file Elephant/elephant/src/main/java/org/turro/queue/Tasks.java.

                                  {
    return getInstance().queue;
  }

Here is the caller graph for this function:

---

The documentation for this class was generated from the following file:

• Elephant/elephant/src/main/java/org/turro/queue/Tasks.java