zmq.pipe

Class DBuffer<T extends Msg>

java.lang.Object

zmq.pipe.DBuffer<T>

class DBuffer<T extends Msg>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private T	back
private T	front
private boolean	hasMsg
private java.util.concurrent.locks.Lock	sync

Constructor Summary

Constructors

Constructor and Description
DBuffer()

Method Summary

Modifier and Type	Method and Description
T	back()
(package private) boolean	checkRead()
T	front()
(package private) T	probe()
(package private) T	read()
(package private) void	write(T msg)

Methods inherited from class java.lang.Object

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

Field Detail

back

private T extends Msg back

front

private T extends Msg front

sync

private final java.util.concurrent.locks.Lock sync

hasMsg

private boolean hasMsg

Constructor Detail

DBuffer

DBuffer()

Method Detail

back

public T back()

front

public T front()

write

void write(T msg)

read

T read()

checkRead

boolean checkRead()

probe

T probe()