ptdb.kernel.database

Class ExecutorThread

java.lang.Object

ptdb.kernel.database.ExecutorThread

All Implemented Interfaces:

java.lang.Runnable

public class ExecutorThread
extends java.lang.Object
implements java.lang.Runnable

Execute the queries asynchronously.

Monitor the asynchronous connection's task queue and execute tasks one by one over a synchronous connection.

Since:

Ptolemy II 10.0

Version:

$Id$

Author:

Ashwini Bijwe, Yousef Alsaeed

Pt.AcceptedRating:

Red (abijwe)

Pt.ProposedRating:

Red (abijwe)

Constructor Summary

Constructors

Constructor and Description
ExecutorThread(TaskQueue taskQueue) Construct an instance of the executor thread that performs tasks one by one from the taskQueue.

Method Summary

Modifier and Type	Method and Description
void	run() Manage the execution of tasks from the task queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorThread

public ExecutorThread(TaskQueue taskQueue)
               throws DBConnectionException

Construct an instance of the executor thread that performs tasks one by one from the taskQueue.

Parameters:

taskQueue - List of Tasks that need to be executed.

Throws:

DBConnectionException - - When we face a problem while creating a database connection. These problems could be that configured connection class does not exist, the path for the database is not found, the container name is incorrect, the connection to the database could not be established etc.

Method Detail

run

public void run()

Manage the execution of tasks from the task queue.

It aborts its working if it encounter an exception or if the processing error flag in the taskQueue is set to true.

Stop execution if the taskQueue is completed and all the tasks are executed or if it exceeds its max wait time of 50 seconds.

Specified by:

run in interface java.lang.Runnable