pt.lsts.neptus.util.concurrency

Class QueueWorkTickets<C>

java.lang.Object

pt.lsts.neptus.util.concurrency.QueueWorkTickets<C>

public class QueueWorkTickets<C>
extends java.lang.Object

This class implements a maximum simultaneous workers and a waiting FIFO queue. It provides a Future for waiting the result and allows adding a Callable to be run upon lease. The callable is run on a separate thread.

Author:

pdias

Constructor Summary

Constructors

Constructor and Description
QueueWorkTickets(int maximumTickets)

Method Summary

Modifier and Type	Method and Description
void	cancelAll()
java.util.ArrayList<C>	getAllWorkingClients()
boolean	isLeased(C client)
boolean	isQueued(C client)
protected boolean	lease(C client) Call this to lease a working ticket.
java.util.concurrent.Future<java.lang.Boolean>	leaseAndWait(C client) The future will hold the lease result.
java.util.concurrent.Future<java.lang.Boolean>	leaseAndWait(C client, java.util.concurrent.Callable<java.lang.Boolean> callable) The future will hold the lease result.
static void	main(java.lang.String[] args)
boolean	release(C client)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueWorkTickets

public QueueWorkTickets(int maximumTickets)

Method Detail

lease

protected boolean lease(C client)

Call this to lease a working ticket. If is immediately granted, return true. If not returns false and one should release(Object) or periodically check with isLeased(Object).

Parameters:

client -

Returns:

leaseAndWait

public java.util.concurrent.Future<java.lang.Boolean> leaseAndWait(C client)

The future will hold the lease result. It is client responsibility to release if result is true.

Parameters:

client -

Returns:

leaseAndWait

public java.util.concurrent.Future<java.lang.Boolean> leaseAndWait(C client,
                                                                   java.util.concurrent.Callable<java.lang.Boolean> callable)

The future will hold the lease result. It is client responsibility to release if result is true.

Parameters:

client -

callable -

Returns:

isLeased

public boolean isLeased(C client)

isQueued

public boolean isQueued(C client)

release

public boolean release(C client)

cancelAll

public void cancelAll()

getAllWorkingClients

public java.util.ArrayList<C> getAllWorkingClients()

Returns:

A copy of the current ticket older workers.

main

public static void main(java.lang.String[] args)

Parameters:

args -