A B C D E F G H I J L M O P Q R S T U V W X

A

Adapter() - Constructor for class xyz.cofe.ipc.process.TaskManager.Adapter

addExceptionListenr(ExceptionListener) - Static method in class xyz.cofe.ipc.process.ProcUtil

Добаляет слушателя исключений

addListener(TaskManager.Listener) - Method in class xyz.cofe.ipc.process.TaskManager

Добавляет подписчика

addThreads(int) - Method in class xyz.cofe.ipc.process.TaskManager

Добавляет указанное кол-во потоков в пул

appendBlock(byte[]) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Добавляет блок в конец очереди, увеличивая ее

available() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

B

blockCount - Variable in class xyz.cofe.ipc.sharedmem.MutableQueueHead

BlockHead - Interface in xyz.cofe.ipc.sharedmem

Заголовок блока данных

blockHeadSize - Static variable in class xyz.cofe.ipc.sharedmem.MutableBlockHead

Размер заголовка

blocks - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

buff - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

buff - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel.InReader

buffLength - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

buffOffset - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

ByteQueue - Class in xyz.cofe.ipc.sharedmem

Очередь байт-сообщений работающая через общуюю память (shared memory) используя синхронизацию (блокировки файлов на уровне ОС и java).

ByteQueue() - Constructor for class xyz.cofe.ipc.sharedmem.ByteQueue

byteQueue - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

byteQueue - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

byteQueue - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

ByteQueue.InStream - Class in xyz.cofe.ipc.sharedmem

ByteQueue.OutStream - Class in xyz.cofe.ipc.sharedmem

C

checkBuffInfo() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Проверка буфера при открытии файла

checkFreeBlocks() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Проверяет наличие свободных блоков, Последовательность (2 и более) пустых блоков объединяет в один блок

checkFreeBlocks(boolean) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Проверяет наличие свободных блоков, Последовательность (2 и более) пустых блоков объединяет в один блок

checkHeadSCN() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Проверяет совпадение SCN номера в заголовке.

close() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

close() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

close() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

close() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

close() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.InReader

close() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.OutWriter

createThread() - Method in class xyz.cofe.ipc.process.TaskManager

Создание класса потока

D

data - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

dataLen - Variable in class xyz.cofe.ipc.sharedmem.MutableBlockHead

decodeString(Charset) - Method in class xyz.cofe.ipc.process.ProcessOutputEvent

Конвертирует полученные данные в строку

delay - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

delay - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

dumpBlocks() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Выводит таблицу блоков на STDIO

dumpBlocks(Writer) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Выводит таблицу блоков

E

Event(TaskManager) - Constructor for class xyz.cofe.ipc.process.TaskManager.Event

Конструктор события

exec(String) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает процесс

exec(String[]) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает процесс

exec(String, String[]) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает процесс

exec(String[], String[]) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает процесс

exec(String, String[], File) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает процесс

exec(String[], String[], File) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает процесс

execQuery(String) - Static method in class xyz.cofe.ipc.process.ProcUtil

Выполняет процесс и возвращает прочитанные данные

execQuery(String, String[], File) - Static method in class xyz.cofe.ipc.process.ProcUtil

Выполняет процесс и возвращает прочитанные данные

execQuery(String, String[], File, String) - Static method in class xyz.cofe.ipc.process.ProcUtil

Выполняет процесс и возвращает прочитанные данные

execQuery(String, String[], File, long, String) - Static method in class xyz.cofe.ipc.process.ProcUtil

Выполняет процесс (shell) и возвращает прочитанные данные

execQuery(String, String[], File, long, String, Charset, Charset, int, long, Charset, int, long) - Static method in class xyz.cofe.ipc.process.ProcUtil

Выполняет процесс (shell) и возвращает прочитанные данные

F

fchannel - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

file - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

file - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

finalize() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

findFreeBlock_WSEMore(int, int) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Ищет свободный блок с указанным размером или больше

fireEvent(TaskManager.Event) - Method in class xyz.cofe.ipc.process.TaskManager

Сообщает о наступлении события подписчикам

fireException(Exception) - Static method in class xyz.cofe.ipc.process.ProcUtil

flush() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

flush() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.OutWriter

G

getAction() - Method in class xyz.cofe.ipc.process.TaskManager.JobQueueEvent

Действие связанное с очередью

getAction() - Method in class xyz.cofe.ipc.process.TaskManager.ThreadEvet

Действие потока

getAction() - Method in class xyz.cofe.ipc.process.TaskManager.ThreadPoolEvent

getBlockCount() - Method in class xyz.cofe.ipc.sharedmem.MutableQueueHead

getBlocksWithData() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Читает блоки и возвращает тек которые содержат данные, в последовательности увел.

getByteQueue() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

getByteQueue() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

getByteQueue() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

getData() - Method in class xyz.cofe.ipc.process.ProcessOutputEvent

Возвращает Данные процесса

getDataLen() - Method in interface xyz.cofe.ipc.sharedmem.BlockHead

Размер данных блока

getDataLen() - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

getDefaultCharset() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает кодировку по умолчанию

getDelay() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

Указывает задержку в цикле чтения данных в нано секундах.

getDelay() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

Указывает задержку в цикле чтения данных в нано секундах.

getDestroyThreadTimeout() - Method in class xyz.cofe.ipc.process.TaskManager

Указывает время уничтожения потока в милисикундах (по умолч. 15 секунд)

getEndDate() - Method in class xyz.cofe.ipc.process.ProcessResult

Возвращает Дата/время конца процесса

getErrorsBufferLength() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает длину буфера ошибок (символы)

getErrorsCharset() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает кодировку потока ошибок

getException() - Method in class xyz.cofe.ipc.process.TaskManager.JobExecuteEvent

Исключение вызвавшее завершение выполнения задачи

getExecutePeriod() - Method in class xyz.cofe.ipc.process.ProcessResult

Возвращает время выполнения процесса в милисекундах

getExitCode() - Method in class xyz.cofe.ipc.process.ProcessResult

Возвращает Код выхода процесса

getExitCode() - Method in class xyz.cofe.ipc.process.ProcessStateEvent

Возвращает код выхода процесса

getFile() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Возвращает файл с которым происходит работа

getFile() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

getId() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

Возвращает уникальный идентификатор объекта (в пределах процесса java.exe)

getInput() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

getInput() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.InReader

getInputCharset() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает кодировку входного потока

getInstances() - Static method in class xyz.cofe.ipc.sharedmem.IpcChannel

Возвращает созданные экземпляры

getJob() - Method in class xyz.cofe.ipc.process.TaskManager.JobExecuteEvent

Выполняемое задание

getJob() - Method in class xyz.cofe.ipc.process.TaskManager.JobQueueEvent

Задание

getListeners() - Method in class xyz.cofe.ipc.process.TaskManager

Возвращает набор подписчиков на события

getLiveThreadsCount() - Method in class xyz.cofe.ipc.process.TaskManager

Возвращает кол-во живых потоков

getLiveThreadsCount() - Method in class xyz.cofe.ipc.process.TaskManager.ThreadPoolEvent

getMaxExecuteProcessTime() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает максимальное допустимое время выполнения процесса в миллисекундах

getMD5Buff() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Возвращает MD5 буфера

getOutput() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

getOutput() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.OutWriter

getOutputBufferLength() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает длину буфера стандартного потока данных (символы)

getOutputCharset() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает кодировку стандартного потока данных

getPosition() - Method in interface xyz.cofe.ipc.sharedmem.BlockHead

Расположение блока в файле

getPosition() - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

getProcess() - Method in class xyz.cofe.ipc.process.ProcessEvent

Возвращает процесс от которого происходит сообщение

getQueue() - Method in class xyz.cofe.ipc.process.TaskManager

Возвращает очередь с заданиями

getQueueSize() - Method in class xyz.cofe.ipc.process.TaskManager.JobQueueEvent

Возвращает размер очереди

getReader() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

getReadTimeout() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

Указывает максимальное время ожидания поступления данных

getReadTimeout() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

Указывает максимальное время ожидания поступления данных

getRepeatCheckWindow() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает время через которое проверять завершение процесса

getSCN() - Method in interface xyz.cofe.ipc.sharedmem.BlockHead

Последовательный номер блока

getSCN() - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

getSCN() - Method in class xyz.cofe.ipc.sharedmem.MutableQueueHead

getSource() - Method in class xyz.cofe.ipc.process.TaskManager.Event

Источник события

getStartDate() - Method in class xyz.cofe.ipc.process.ProcessResult

Возвращает Дата/время начала процесса

getState() - Method in class xyz.cofe.ipc.process.ProcessStateEvent

Возвращает состояние процесса

getStderr() - Method in class xyz.cofe.ipc.process.ProcessResult

Возвращает Резултат вывода процесса через поток ошибок

getStdout() - Method in class xyz.cofe.ipc.process.ProcessResult

Возвращает Резултат вывода процесса через стандартный поток

getThread() - Method in class xyz.cofe.ipc.process.TaskManager.ThreadEvet

Возвращает поток связанный с событием

getThreadPoolSize() - Method in class xyz.cofe.ipc.process.TaskManager

Указывает кол-во потоков

getThreadSleepTimeout() - Method in class xyz.cofe.ipc.process.TaskManager

getUnionOutputAndErrors() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает объединять поток ошибок и стандартный поток (в стандартный)

getWaitReadErrorsWindow() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает время через которое проверять наличии данных в потоке stderr (0 - без задержки)

getWaitReadOutputWindow() - Static method in class xyz.cofe.ipc.process.ProcUtil

Возвращает время через которое проверять наличии данных в потоке stdout (0 - без задержки)

getWriter() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

H

hasData - Variable in class xyz.cofe.ipc.sharedmem.MutableBlockHead

hasOwnerLock() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Очередь имеет блокировку владельца

hasOwnerLock() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

Очередь имеет блокировку владельца

head - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

I

id - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

idseq - Static variable in class xyz.cofe.ipc.sharedmem.IpcChannel

input - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

input - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel.InReader

InReader(ByteQueue.InStream) - Constructor for class xyz.cofe.ipc.sharedmem.IpcChannel.InReader

instances - Static variable in class xyz.cofe.ipc.sharedmem.IpcChannel

InStream(ByteQueue) - Constructor for class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

IpcChannel - Class in xyz.cofe.ipc.sharedmem

Канал данных

IpcChannel() - Constructor for class xyz.cofe.ipc.sharedmem.IpcChannel

IpcChannel(String) - Constructor for class xyz.cofe.ipc.sharedmem.IpcChannel

IpcChannel(File) - Constructor for class xyz.cofe.ipc.sharedmem.IpcChannel

IpcChannel(File) - Constructor for class xyz.cofe.ipc.sharedmem.IpcChannel

IpcChannel.InReader - Class in xyz.cofe.ipc.sharedmem

IpcChannel.OutWriter - Class in xyz.cofe.ipc.sharedmem

isCancel() - Method in class xyz.cofe.ipc.process.TaskManager.JobCancelQueueEvent

Действие отменено

isClosed() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

isClosed() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

isClosed() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

isClosed() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.InReader

isClosed() - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.OutWriter

isHasData() - Method in interface xyz.cofe.ipc.sharedmem.BlockHead

Данные присуствуют

isHasData() - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

isRunning() - Method in class xyz.cofe.ipc.process.TaskManager

Возвращает флаг активности

isThreadDeamon() - Method in class xyz.cofe.ipc.process.TaskManager

Указывает использовать daemon режим

J

JobCancelQueueEvent(TaskManager, TaskManager.QueueAction, Runnable, int) - Constructor for class xyz.cofe.ipc.process.TaskManager.JobCancelQueueEvent

jobExecuteEvent(TaskManager.JobExecuteEvent) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

Обрабатывает событие потока, распределяя его по onJobAdd, onJobRemove

JobExecuteEvent(TaskManager, Thread, TaskManager.ThreadAction, Runnable) - Constructor for class xyz.cofe.ipc.process.TaskManager.JobExecuteEvent

Конструктор события

JobExecuteEvent(TaskManager, Thread, TaskManager.ThreadAction, Runnable, Throwable) - Constructor for class xyz.cofe.ipc.process.TaskManager.JobExecuteEvent

Конструктор события

jobQueueEvent(TaskManager.JobQueueEvent) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

Обрабатывает событие очереди, распределяя его по onJobAdd, onJobRemove

JobQueueEvent(TaskManager, TaskManager.QueueAction, Runnable, int) - Constructor for class xyz.cofe.ipc.process.TaskManager.JobQueueEvent

joinBlocks(List<MutableBlockHead>) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

L

lockHead() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

logFreeBlocks() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Лог по свободным блокам

M

main(String[]) - Static method in class xyz.cofe.ipc.process.Test

markSupported() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

MutableBlockHead - Class in xyz.cofe.ipc.sharedmem

Изменяемый заголовок блока данных

MutableBlockHead() - Constructor for class xyz.cofe.ipc.sharedmem.MutableBlockHead

MutableQueueHead - Class in xyz.cofe.ipc.sharedmem

MutableQueueHead() - Constructor for class xyz.cofe.ipc.sharedmem.MutableQueueHead

O

onJobAdd(TaskManager, Runnable, TaskManager.JobCancelQueueEvent) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

Работа добавляется в очередь

onJobFinished(TaskManager, Thread, Runnable, Throwable) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

onJobRemove(TaskManager, Runnable) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

onJobStarted(TaskManager, Thread, Runnable) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

onThreadPoolStarted(TaskManager, int) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

onThreadPoolStopped(TaskManager, int) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

onThreadStarted(TaskManager, Thread) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

onThreadStopped(TaskManager, Thread) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

open(File) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

output - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

output - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel.OutWriter

OutStream(ByteQueue) - Constructor for class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

OutWriter(ByteQueue.OutStream) - Constructor for class xyz.cofe.ipc.sharedmem.IpcChannel.OutWriter

ownerLock - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

P

pointer - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

position - Variable in class xyz.cofe.ipc.sharedmem.MutableBlockHead

ProcessAdapter - Class in xyz.cofe.ipc.process

Адаптер слушателья процесса

ProcessAdapter() - Constructor for class xyz.cofe.ipc.process.ProcessAdapter

ProcessController - Class in xyz.cofe.ipc.process

Контроллер процесса

ProcessController() - Constructor for class xyz.cofe.ipc.process.ProcessController

processEvent(ProcessEvent) - Method in class xyz.cofe.ipc.process.ProcessAdapter

Сообщение для слушателя

ProcessEvent - Class in xyz.cofe.ipc.process

Сообщение процесса

ProcessEvent(Object, Process) - Constructor for class xyz.cofe.ipc.process.ProcessEvent

Конструктор

processEvent(ProcessEvent) - Method in interface xyz.cofe.ipc.process.ProcessListener

Сообщение для слушателя

ProcessListener - Interface in xyz.cofe.ipc.process

Слушатель процесса

processOutput(ProcessOutputEvent) - Method in class xyz.cofe.ipc.process.ProcessAdapter

Сообщение передачи данных через стандартный поток (или другой какой либо поток)

ProcessOutputEvent - Class in xyz.cofe.ipc.process

Сообщение процесса: вывода информации через поток

ProcessOutputEvent(Object, Process, byte[]) - Constructor for class xyz.cofe.ipc.process.ProcessOutputEvent

Констркуктор

ProcessResult - Class in xyz.cofe.ipc.process

Описывает результат вызова программы

ProcessResult(String, String, int, Date, Date) - Constructor for class xyz.cofe.ipc.process.ProcessResult

Конструктор

ProcessState - Enum in xyz.cofe.ipc.process

Состояния процесса

ProcessStateEvent - Class in xyz.cofe.ipc.process

Сообщение о измении состояния процесса

ProcessStateEvent(Object, Process, ProcessState, int) - Constructor for class xyz.cofe.ipc.process.ProcessStateEvent

Конструктор

processTerminated(int) - Method in class xyz.cofe.ipc.process.ProcessAdapter

Процесс завершил существование

processTerminated(int, Process) - Method in class xyz.cofe.ipc.process.ProcessAdapter

Процесс завершил существование

ProcUtil - Class in xyz.cofe.ipc.process

Вспомагательный класс по работе с процессами

ProcUtil() - Constructor for class xyz.cofe.ipc.process.ProcUtil

Q

queueHeadSize - Static variable in class xyz.cofe.ipc.sharedmem.MutableQueueHead

R

raFile - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue

read(byte[], int, int) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

read(byte[]) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

read() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

read(char[], int, int) - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.InReader

read(MappedByteBuffer, int) - Static method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

read(MappedByteBuffer) - Static method in class xyz.cofe.ipc.sharedmem.MutableQueueHead

readBlockHeaders() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Блокирует head
Читает заголовки
Снимает блокировку head

readBlocks(OutputStream) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Читает блоки с данными, отмечает их как не содержащие данные Устанавливает блокирову head.

readBlocksTo(OutputStream) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Читает блоки с данными и записывает их в указанный поток.

readData() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

readData(MappedByteBuffer) - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

reader - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

readTimeout - Variable in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

readTimeout - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

removeExceptionListener(ExceptionListener) - Static method in class xyz.cofe.ipc.process.ProcUtil

Удаляет слушателя исключений

removeListener(TaskManager.Listener) - Method in class xyz.cofe.ipc.process.TaskManager

Удаляет подписчика

removeThreads(int) - Method in class xyz.cofe.ipc.process.TaskManager

Удаляет указанное кол-во потоков из пула

rereadBlockHeaders() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Перепрочитывает заголовки, предпологается что блокировка head, установлена

resetHeaders() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

runProcessExitListener(Process, ProcessListener, SyncFlag) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает слушаетля процесса в отдельном фоновом потоке, для ожидания завершения процесса.

runProcessReaderListener(Process, ProcessListener, InputStream, SyncFlag) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает слушаетля процесса в отдельном фоновом потоке, для получения входных данных Поток завершит прослушивание в случае, если процесс перестанет существовать или будет установлен флаг в значени true

runProcessReaderListener(Process, ProcessListener, InputStream, int, SyncFlag) - Static method in class xyz.cofe.ipc.process.ProcUtil

Запускает слушаетля процесса в отдельном фоновом потоке, для получения входных данных Поток завершит прослушивание в случае, если процесс перестанет существовать или будет установлен флаг в значени true

S

scn - Variable in class xyz.cofe.ipc.sharedmem.MutableBlockHead

scn - Variable in class xyz.cofe.ipc.sharedmem.MutableQueueHead

setBlockCount(int) - Method in class xyz.cofe.ipc.sharedmem.MutableQueueHead

setCancel(boolean) - Method in class xyz.cofe.ipc.process.TaskManager.JobCancelQueueEvent

Действие отменено

setDataLen(int) - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

setDefaultCharset(Charset) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает кодировку по умолчанию

setDelay(long) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

Указывает задержку в цикле чтения данных в нано секундах.

setDelay(long) - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

Указывает задержку в цикле чтения данных в нано секундах.

setDestroyThreadTimeout(long) - Method in class xyz.cofe.ipc.process.TaskManager

Указывает время уничтожения потока в милисикундах (по умолч. 15 секунд)

setErrorsBufferLength(Integer) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает длину буфера ошибок (символы)

setErrorsCharset(Charset) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает кодировку потока ошибок

setFile(File) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Указывает файл с которым происходит работа

setFile(File) - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

setHasData(boolean) - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

setInputCharset(Charset) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает кодировку входного потока

setMaxExecuteProcessTime(Long) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает максимальное допустимое время выполнения процесса в миллисекундах

setOutputBufferLength(Integer) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает длину буфера стандартного потока данных (символы)

setOutputCharset(Charset) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает кодировку стандартного потока данных

setPosition(int) - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

setReadTimeout(int) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.InStream

Указывает максимальное время ожидания поступления данных

setReadTimeout(int) - Method in class xyz.cofe.ipc.sharedmem.IpcChannel

Указывает максимальное время ожидания поступления данных

setRepeatCheckWindow(Long) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает время через которое проверять завершение процесса

setSCN(long) - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

setSCN(long) - Method in class xyz.cofe.ipc.sharedmem.MutableQueueHead

setThreadDeamon(boolean) - Method in class xyz.cofe.ipc.process.TaskManager

setThreadPoolSize(int) - Method in class xyz.cofe.ipc.process.TaskManager

Указывает кол-во потоков

setThreadSleepTimeout(long) - Method in class xyz.cofe.ipc.process.TaskManager

setUnionOutputAndErrors(Boolean) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает объединять поток ошибок и стандартный поток (в стандартный)

setWaitReadErrorsWindow(Long) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает время через которое проверять наличии данных в потоке stderr (0 - без задержки)

setWaitReadOutputWindow(Long) - Static method in class xyz.cofe.ipc.process.ProcUtil

Устанавливает время через которое проверять наличии данных в потоке stdout (0 - без задержки)

splitBlock(MutableBlockHead, int) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Разделяет блок на два,
Блоки не заносятся в таблицу блоков и не сохраняются в shared mem.

start() - Method in class xyz.cofe.ipc.process.TaskManager

Инициализация пула потоков

stop() - Method in class xyz.cofe.ipc.process.TaskManager

Уничтожение пула потоков

SyncFlag - Class in xyz.cofe.ipc.process

Синхронный флаг

SyncFlag(boolean) - Constructor for class xyz.cofe.ipc.process.SyncFlag

Конструктор

T

TaskManager - Class in xyz.cofe.ipc.process

Менеджер задач.

TaskManager() - Constructor for class xyz.cofe.ipc.process.TaskManager

TaskManager.Adapter - Class in xyz.cofe.ipc.process

Адаптер подписчика на сообщения

TaskManager.Event - Class in xyz.cofe.ipc.process

Событие менеджера задач.

TaskManager.JobCancelQueueEvent - Class in xyz.cofe.ipc.process

Событие очереди

TaskManager.JobExecuteEvent - Class in xyz.cofe.ipc.process

Событие выполнения задания

TaskManager.JobQueueEvent - Class in xyz.cofe.ipc.process

Событие очереди

TaskManager.Listener - Interface in xyz.cofe.ipc.process

Подписчик на события менеджера задач

TaskManager.QueueAction - Enum in xyz.cofe.ipc.process

Действие очереди

TaskManager.ThreadAction - Enum in xyz.cofe.ipc.process

Действие потока

TaskManager.ThreadEvet - Class in xyz.cofe.ipc.process

События происходящие в потоке

TaskManager.ThreadPoolAction - Enum in xyz.cofe.ipc.process

TaskManager.ThreadPoolEvent - Class in xyz.cofe.ipc.process

taskManagerEvent(TaskManager.Event) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

Обрабатывает событие распределяя его по функциям

taskManagerEvent(TaskManager.Event) - Method in interface xyz.cofe.ipc.process.TaskManager.Listener

Принимает события происходящии в менеджере задач, как-то добавление новый заданий, или неудачное выполнение задачи, и д.р.

Test - Class in xyz.cofe.ipc.process

Тестирование

Test() - Constructor for class xyz.cofe.ipc.process.Test

threadEvent(TaskManager.ThreadEvet) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

Обрабатывает событие потока, распределяя его по onThreadStarted, onThreadStopped, jobExecuteEvent

ThreadEvet(TaskManager, Thread, TaskManager.ThreadAction) - Constructor for class xyz.cofe.ipc.process.TaskManager.ThreadEvet

threadPoolEvent(TaskManager.ThreadPoolEvent) - Method in class xyz.cofe.ipc.process.TaskManager.Adapter

Обрабатывает событие пула, распределяя его по onThreadPoolStarted, onThreadPoolStopped

ThreadPoolEvent(TaskManager, TaskManager.ThreadPoolAction, int) - Constructor for class xyz.cofe.ipc.process.TaskManager.ThreadPoolEvent

tryInsert(byte[]) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

U

unlockHead(FileLock) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

V

value() - Method in class xyz.cofe.ipc.process.SyncFlag

Возвращает значени флага

value(boolean) - Method in class xyz.cofe.ipc.process.SyncFlag

Устанавливает значение флага

valueOf(String) - Static method in enum xyz.cofe.ipc.process.ProcessState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum xyz.cofe.ipc.process.TaskManager.QueueAction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum xyz.cofe.ipc.process.TaskManager.ThreadAction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum xyz.cofe.ipc.process.TaskManager.ThreadPoolAction

Returns the enum constant of this type with the specified name.

values() - Static method in enum xyz.cofe.ipc.process.ProcessState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum xyz.cofe.ipc.process.TaskManager.QueueAction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum xyz.cofe.ipc.process.TaskManager.ThreadAction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum xyz.cofe.ipc.process.TaskManager.ThreadPoolAction

Returns an array containing the constants of this enum type, in the order they are declared.

W

write(byte[]) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

write(byte[], int, int) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

write(int) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue.OutStream

write(char[], int, int) - Method in class xyz.cofe.ipc.sharedmem.IpcChannel.OutWriter

write(MappedByteBuffer) - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

write(MappedByteBuffer) - Method in class xyz.cofe.ipc.sharedmem.MutableQueueHead

writeBlock(byte[]) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Последовательность действий Устанавливает блокировку head Проверяет SCN Увеличивает SCN на 1 Добавляет блок данных в конец очереди SCN текущий Записывает блок и его заголовок в shared mem Обновляет заголовок очереди в shared mem Снимает блокировку head

writeBuffInfo() - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Записывает MD5 буфера в начало файла

writeData(MappedByteBuffer, byte[]) - Method in class xyz.cofe.ipc.sharedmem.MutableBlockHead

writeFirstBlock(byte[]) - Method in class xyz.cofe.ipc.sharedmem.ByteQueue

Создаеи первый блок

writer - Variable in class xyz.cofe.ipc.sharedmem.IpcChannel

X

xyz.cofe.ipc.process - package xyz.cofe.ipc.process

Инструменты по работе с процессами ОС.

xyz.cofe.ipc.sharedmem - package xyz.cofe.ipc.sharedmem

A B C D E F G H I J L M O P Q R S T U V W X