ThreadMonitorImpl (cxscript 0.2.2 API)

java.lang.Object
- xyz.cofe.cxconsole.script.jsr233.ThreadMonitorImpl<Script>

All Implemented Interfaces:

ExecuteMonitor<Script>, ExecuteResult<Script>
```
public class ThreadMonitorImpl<Script>
extends Object
implements ExecuteMonitor<Script>, ExecuteResult<Script>
```
Монитор выполнения скрипта - рабочих треод.
При старте запускает скрипт в отредльном треде (а если надо, то и ThreadGroup)

Author:

Kamnev Georgiy (nt.gocha@gmail.com)

Field Summary

Fields
Modifier and Type	Field and Description
`protected ClassLoader`	`cl`
`protected Boolean`	`daemon`
`protected String`	`name`
`protected Integer`	`prio`
`protected Script`	`script`
`protected Throwable`	`scriptError`
`protected Object`	`scriptResult`
`protected xyz.cofe.collection.Func0<xyz.cofe.collection.Pair<Object,Throwable>>`	`scriptRun`
`protected boolean`	`tgFinishNotifyOnError`
`protected Thread`	`thread`
`protected ThreadGroup`	`threadGroup`

Constructor Summary

Constructors
Constructor and Description

ThreadMonitorImpl(Script script, xyz.cofe.collection.Func0<xyz.cofe.collection.Pair<Object,Throwable>> run)
Конструктор

Constructors
Constructor and Description
`ThreadMonitorImpl(Script script, xyz.cofe.collection.Func0<xyz.cofe.collection.Pair<Object,Throwable>> run)` Конструктор

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`ThreadMonitorImpl<Script>`	`cancel()` Отмена выполнения.
`protected Thread`	`createThread()`
`static List<Thread>`	`exclude(Iterable<Thread> thList, xyz.cofe.collection.Func1<Boolean,Thread> filter)`
`static List<Thread>`	`filter(Iterable<Thread> thList, xyz.cofe.collection.Func1<Boolean,Thread> filter)`
`static List<Thread>`	`filter(Iterable<Thread> thList, xyz.cofe.collection.Predicate<Thread> filter)`
`long`	`getCancelDelay()`
`long`	`getCancelTimeout()`
`ClassLoader`	`getContextClassLoader()`
`Boolean`	`getDaemon()`
`Throwable`	`getError()` Ошибка выполнения
`xyz.cofe.collection.Func1<Boolean,Thread>`	`getExcludeFilter()`
`Date`	`getFinished()` Дата завершения выполнения скрипта
`Integer`	`getPrio()`
`Object`	`getResult()` Результат выполнения
`Script`	`getScript()` Возвращает выполняемый/выполненый скрипт
`Date`	`getStarted()` Дата начала выполнения скрипта
`Thread`	`getThread()`
`ThreadGroup`	`getThreadGroup()`
`String`	`getThreadName()`
`boolean`	`isRunning()` Проверяет состояние выполнения
`boolean`	`isTgFinishNotifyOnError()`
`ThreadMonitorImpl<Script>`	`join()` Ждет завершения скрипта
`ThreadMonitorImpl<Script>`	`join(long millis)` Ждет завершения скрипта, указанное время
`Closeable`	`onFinished(xyz.cofe.common.Reciver<ExecuteResult<Script>> consumer)` При завершении выполнения вызывает указанного "подписчика"
`Closeable`	`onFinished(xyz.cofe.common.Reciver<ExecuteResult<Script>> consumer, boolean weakListener)` При завершении выполнения вызывает указанного "подписчика"
`void`	`onThreadCreated(xyz.cofe.common.Reciver<Thread> consumer)`
`void`	`setCancelDelay(long ms)`
`void`	`setCancelTimeout(long ms)`
`void`	`setContextClassLoader(ClassLoader cl)`
`void`	`setDaemon(Boolean daemon)`
`void`	`setExcludeFilter(xyz.cofe.collection.Func1<Boolean,Thread> excludeFilter)`
`void`	`setFinished(Date d)`
`void`	`setPrio(Integer p)`
`void`	`setTgFinishNotifyOnError(boolean tgFinishNotifyOnError)`
`void`	`setThreadGroup(ThreadGroup tg)`
`void`	`setThreadName(String name)`
`ThreadMonitorImpl<Script>`	`start()` Выполняет скрипт
`ThreadMonitorImpl<Script>`	`startCancel(xyz.cofe.common.Reciver<ExecuteResult<Script>> consumer)` Отмена выполнения асинхронно.
`static List<Thread>`	`threadsOf(ThreadGroup tg)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - threadGroup
```
protected ThreadGroup threadGroup
```
  - scriptRun
```
protected xyz.cofe.collection.Func0<xyz.cofe.collection.Pair<Object,Throwable>> scriptRun
```
  - prio
```
protected Integer prio
```
  - daemon
```
protected Boolean daemon
```
  - cl
```
protected ClassLoader cl
```
  - name
```
protected String name
```
  - tgFinishNotifyOnError
```
protected boolean tgFinishNotifyOnError
```
  - thread
```
protected Thread thread
```
  - script
```
protected Script script
```
  - scriptResult
```
protected volatile Object scriptResult
```
  - scriptError
```
protected volatile Throwable scriptError
```
- Constructor Detail
  - ThreadMonitorImpl
```
public ThreadMonitorImpl(Script script,
                         xyz.cofe.collection.Func0<xyz.cofe.collection.Pair<Object,Throwable>> run)
```
    Конструктор
    
    Parameters:
    
    script - Выполняемый скрипт
    
    run - Функция выполнения скрипта, возвращает Pair<Результат,Ошибка скрипта>
- Method Detail
  - getThreadGroup
```
public ThreadGroup getThreadGroup()
```
  - setThreadGroup
```
public void setThreadGroup(ThreadGroup tg)
```
  - getPrio
```
public Integer getPrio()
```
  - setPrio
```
public void setPrio(Integer p)
```
  - getDaemon
```
public Boolean getDaemon()
```
  - setDaemon
```
public void setDaemon(Boolean daemon)
```
  - getContextClassLoader
```
public ClassLoader getContextClassLoader()
```
  - setContextClassLoader
```
public void setContextClassLoader(ClassLoader cl)
```
  - setThreadName
```
public void setThreadName(String name)
```
  - getThreadName
```
public String getThreadName()
```
  - onThreadCreated
```
public void onThreadCreated(xyz.cofe.common.Reciver<Thread> consumer)
```
  - isTgFinishNotifyOnError
```
public boolean isTgFinishNotifyOnError()
```
  - setTgFinishNotifyOnError
```
public void setTgFinishNotifyOnError(boolean tgFinishNotifyOnError)
```
  - createThread
```
protected Thread createThread()
```
  - getThread
```
public Thread getThread()
```
  - start
```
public ThreadMonitorImpl<Script> start()
```
    Description copied from interface: ExecuteMonitor
    
    Выполняет скрипт
    
    Specified by:
    
    start in interface ExecuteMonitor<Script>
    
    Returns:
    
    self ссылка
  - getScript
```
public Script getScript()
```
    Description copied from interface: ExecuteMonitor
    
    Возвращает выполняемый/выполненый скрипт
    
    Specified by:
    
    getScript in interface ExecuteMonitor<Script>
    
    Specified by:
    
    getScript in interface ExecuteResult<Script>
    
    Returns:
    
    скрипт
  - getResult
```
public Object getResult()
```
    Description copied from interface: ExecuteMonitor
    
    Результат выполнения
    
    Specified by:
    
    getResult in interface ExecuteMonitor<Script>
    
    Specified by:
    
    getResult in interface ExecuteResult<Script>
    
    Returns:
    
    Результат выполнения
  - getError
```
public Throwable getError()
```
    Description copied from interface: ExecuteMonitor
    
    Ошибка выполнения
    
    Specified by:
    
    getError in interface ExecuteMonitor<Script>
    
    Specified by:
    
    getError in interface ExecuteResult<Script>
    
    Returns:
    
    Ошибка выполнения
  - isRunning
```
public boolean isRunning()
```
    Description copied from interface: ExecuteMonitor
    
    Проверяет состояние выполнения
    
    Specified by:
    
    isRunning in interface ExecuteMonitor<Script>
    
    Returns:
    
    true - скрипт выполняется
  - getStarted
```
public Date getStarted()
```
    Description copied from interface: ExecuteMonitor
    
    Дата начала выполнения скрипта
    
    Specified by:
    
    getStarted in interface ExecuteMonitor<Script>
    
    Returns:
    
    дата начала или null
  - getFinished
```
public Date getFinished()
```
    Description copied from interface: ExecuteMonitor
    
    Дата завершения выполнения скрипта
    
    Specified by:
    
    getFinished in interface ExecuteMonitor<Script>
    
    Returns:
    
    дата завершения скрипта
  - setFinished
```
public void setFinished(Date d)
```
  - onFinished
```
public Closeable onFinished(xyz.cofe.common.Reciver<ExecuteResult<Script>> consumer,
                            boolean weakListener)
```
    Description copied from interface: ExecuteMonitor
    
    При завершении выполнения вызывает указанного "подписчика"
    
    Specified by:
    
    onFinished in interface ExecuteMonitor<Script>
    
    Parameters:
    
    consumer - подписчик на сообщения завершения работы
    
    weakListener - добавить подписчика как weak ссылку
    
    Returns:
    
    Отписка от сообщения
  - onFinished
```
public Closeable onFinished(xyz.cofe.common.Reciver<ExecuteResult<Script>> consumer)
```
    Description copied from interface: ExecuteMonitor
    
    При завершении выполнения вызывает указанного "подписчика"
    
    Specified by:
    
    onFinished in interface ExecuteMonitor<Script>
    
    Parameters:
    
    consumer - подписчик на сообщения завершения работы
    
    Returns:
    
    Отписка от сообщения
  - cancel
```
public ThreadMonitorImpl<Script> cancel()
```
    Description copied from interface: ExecuteMonitor
    
    Отмена выполнения.
    
    Specified by:
    
    cancel in interface ExecuteMonitor<Script>
    
    Returns:
    
    self ссылка
  - startCancel
```
public ThreadMonitorImpl<Script> startCancel(xyz.cofe.common.Reciver<ExecuteResult<Script>> consumer)
```
    Description copied from interface: ExecuteMonitor
    
    Отмена выполнения асинхронно.
    
    Specified by:
    
    startCancel in interface ExecuteMonitor<Script>
    
    Parameters:
    
    consumer - - будет вызван по завершению операции отмены
    
    Returns:
    
    self ссылка
  - getCancelDelay
```
public long getCancelDelay()
```
  - setCancelDelay
```
public void setCancelDelay(long ms)
```
  - getCancelTimeout
```
public long getCancelTimeout()
```
  - setCancelTimeout
```
public void setCancelTimeout(long ms)
```
  - join
```
public ThreadMonitorImpl<Script> join()
```
    Description copied from interface: ExecuteMonitor
    
    Ждет завершения скрипта
    
    Specified by:
    
    join in interface ExecuteMonitor<Script>
    
    Returns:
    
    self ссылка
  - join
```
public ThreadMonitorImpl<Script> join(long millis)
```
    Description copied from interface: ExecuteMonitor
    
    Ждет завершения скрипта, указанное время
    
    Specified by:
    
    join in interface ExecuteMonitor<Script>
    
    Parameters:
    
    millis - время в милисек.
    
    Returns:
    
    self ссылка
  - getExcludeFilter
```
public xyz.cofe.collection.Func1<Boolean,Thread> getExcludeFilter()
```
  - setExcludeFilter
```
public void setExcludeFilter(xyz.cofe.collection.Func1<Boolean,Thread> excludeFilter)
```
  - threadsOf
```
public static List<Thread> threadsOf(ThreadGroup tg)
```
  - exclude
```
public static List<Thread> exclude(Iterable<Thread> thList,
                                   xyz.cofe.collection.Func1<Boolean,Thread> filter)
```
  - filter
```
public static List<Thread> filter(Iterable<Thread> thList,
                                  xyz.cofe.collection.Func1<Boolean,Thread> filter)
```
  - filter
```
public static List<Thread> filter(Iterable<Thread> thList,
                                  xyz.cofe.collection.Predicate<Thread> filter)
```

Class ThreadMonitorImpl<Script>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

threadGroup

scriptRun

prio

daemon

cl

name

tgFinishNotifyOnError

thread

script

scriptResult

scriptError

Constructor Detail

ThreadMonitorImpl

Method Detail

getThreadGroup

setThreadGroup

getPrio

setPrio

getDaemon

setDaemon

getContextClassLoader

setContextClassLoader

setThreadName

getThreadName

onThreadCreated

isTgFinishNotifyOnError

setTgFinishNotifyOnError

createThread

getThread

start

getScript

getResult

getError

isRunning

getStarted

getFinished

setFinished

onFinished

onFinished

cancel

startCancel

getCancelDelay

setCancelDelay

getCancelTimeout

setCancelTimeout

join

join

getExcludeFilter

setExcludeFilter

threadsOf

exclude

filter

filter