com.caucho.util

Class RingBlockerBasic

java.lang.Object

com.caucho.util.RingBlockerBasic

All Implemented Interfaces:

TaskWorker, RingBlocker

public class RingBlockerBasic
extends java.lang.Object
implements RingBlocker

Ring blocking algorithm.

Constructor Summary

Constructors

Constructor and Description
RingBlockerBasic()

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isOfferWait()
boolean	isPollWait()
boolean	offerWait(long tail, java.util.concurrent.atomic.AtomicLong tailRef, int reservedSpace, long timeout, java.util.concurrent.TimeUnit unit)
void	offerWake()
boolean	pollWait(long timeout, java.util.concurrent.TimeUnit unit)
void	pollWake()
void	wake()

Methods inherited from class java.lang.Object

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

Constructor Detail

RingBlockerBasic

public RingBlockerBasic()

Method Detail

offerWait

public final boolean offerWait(long tail,
                               java.util.concurrent.atomic.AtomicLong tailRef,
                               int reservedSpace,
                               long timeout,
                               java.util.concurrent.TimeUnit unit)

Specified by:

offerWait in interface RingBlocker

isOfferWait

public final boolean isOfferWait()

Specified by:

isOfferWait in interface RingBlocker

offerWake

public final void offerWake()

Specified by:

offerWake in interface RingBlocker

wake

public final void wake()

Specified by:

wake in interface TaskWorker

pollWait

public final boolean pollWait(long timeout,
                              java.util.concurrent.TimeUnit unit)

Specified by:

pollWait in interface RingBlocker

isPollWait

public final boolean isPollWait()

Specified by:

isPollWait in interface RingBlocker

pollWake

public final void pollWake()

Specified by:

pollWake in interface RingBlocker

close

public final void close()

Specified by:

close in interface RingBlocker