public class IpcChannel extends Object implements Closeable
| Modifier and Type | Class and Description |
|---|---|
static class |
IpcChannel.InReader |
static class |
IpcChannel.OutWriter |
| Modifier and Type | Field and Description |
|---|---|
protected ByteQueue |
byteQueue |
protected long |
delay |
protected File |
file |
protected int |
id |
protected static AtomicInteger |
idseq |
protected ByteQueue.InStream |
input |
protected static WeakHashMap<IpcChannel,Boolean> |
instances |
protected ByteQueue.OutStream |
output |
protected IpcChannel.InReader |
reader |
protected int |
readTimeout |
protected IpcChannel.OutWriter |
writer |
| Constructor and Description |
|---|
IpcChannel() |
IpcChannel(File file) |
IpcChannel(File file) |
IpcChannel(String file) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
protected void |
finalize() |
ByteQueue |
getByteQueue() |
long |
getDelay()
Указывает задержку в цикле чтения данных в нано секундах.
|
File |
getFile() |
int |
getId()
Возвращает уникальный идентификатор объекта (в пределах процесса java.exe)
|
ByteQueue.InStream |
getInput() |
static IpcChannel[] |
getInstances()
Возвращает созданные экземпляры
|
ByteQueue.OutStream |
getOutput() |
IpcChannel.InReader |
getReader() |
int |
getReadTimeout()
Указывает максимальное время ожидания поступления данных
|
IpcChannel.OutWriter |
getWriter() |
boolean |
hasOwnerLock()
Очередь имеет блокировку владельца
|
void |
setDelay(long d)
Указывает задержку в цикле чтения данных в нано секундах.
|
void |
setFile(File file) |
void |
setReadTimeout(int readTimeout)
Указывает максимальное время ожидания поступления данных
|
protected static final AtomicInteger idseq
protected final int id
protected static final WeakHashMap<IpcChannel,Boolean> instances
protected File file
protected ByteQueue byteQueue
protected int readTimeout
protected long delay
protected ByteQueue.InStream input
protected ByteQueue.OutStream output
protected IpcChannel.InReader reader
protected IpcChannel.OutWriter writer
public IpcChannel()
public IpcChannel(String file)
public IpcChannel(File file)
public IpcChannel(File file)
public static IpcChannel[] getInstances()
public int getId()
public File getFile()
public void setFile(File file)
public void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableIOExceptionprotected void finalize()
throws Throwable
public ByteQueue getByteQueue()
public boolean hasOwnerLock()
public int getReadTimeout()
public void setReadTimeout(int readTimeout)
readTimeout - макс. время ожидания в милисекундах или -1 - бесколнечноpublic long getDelay()
public void setDelay(long d)
d - задержкаpublic ByteQueue.InStream getInput()
public ByteQueue.OutStream getOutput()
public IpcChannel.InReader getReader()
public IpcChannel.OutWriter getWriter()
Copyright © 2018. All rights reserved.