xyz.cofe.cxconsole.script

Class ScriptService

java.lang.Object

xyz.cofe.cxconsole.srvc.AbstractService

xyz.cofe.cxconsole.srvc.StartableService

xyz.cofe.cxconsole.script.ScriptService

All Implemented Interfaces:

ConsoleService, ScriptEventSender<String>, ServiceEventPublisher, StartService

public class ScriptService
extends StartableService
implements ScriptEventSender<String>

Служба по работе с скриптами

Author:

Kamnev Georgiy (nt.gocha@gmail.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected EngineBindings	bindings
protected EventMap<String,ClassLoaderBuilder>	classLoaderBuilders
protected WeakHashMap<ClassLoaderBuilder,xyz.cofe.cxconsole.script.ScriptService.CLB2B>	classLoadersCache
protected boolean	enginesCaching
protected boolean	running
protected ScriptEventSupport<String>	scriptEventSender
protected ThFilters	thFilters

Fields inherited from class xyz.cofe.cxconsole.srvc.StartableService

startCallLevel, startStopSync, stopCallLevel

Fields inherited from class xyz.cofe.cxconsole.srvc.AbstractService

serviceEventQueue

Constructor Summary

Constructors

Constructor and Description
ScriptService()

Method Summary

Modifier and Type	Method and Description
void	addScriptEvent(ScriptEvent<String> ev)
Closeable	addScriptListener(ScriptListener<String> listener)
Closeable	addScriptListener(ScriptListener<String> listener, boolean weakLink)
void	cache(String id, Engine en)
ClassLoader	classLoader4engine(String engineId)
void	cleanupExecutedTasks(long timeout)
<Script> ThreadMonitorImpl<Script>	createThreadMonitor(Script script, xyz.cofe.collection.Func0<xyz.cofe.collection.Pair<Object,Throwable>> run) Создание монитора скрипта
org.mapdb.HTreeMap<String,Engine>	enginesStoreMap()
void	fireScriptEvent(ScriptEvent<String> event)
void	fireScriptEvents()
EngineBindings	getBindings()
EventMap<String,ClassLoaderBuilder>	getClassLoaderBuilders()
EventMap<String,ClassLoaderFactory>	getClassLoaderFactories()
Map<String,String>	getEngine2ClassLoaderMap() Соответствие имя движка => имя загрузчика (classLoaderBuilder)
EventMap<String,EngineFactory>	getEngineFactories() Фабрики движков
EventMap<String,Engine>	getEngines() Возвращает карту скриптовых движков
MapDB2Service	getMapDB2Service()
Queue<ScriptEvent<String>>	getScriptEventQueue()
ScriptEventSupport<String>	getScriptEventSender()
Set<ScriptListener<String>>	getScriptListeners()
xyz.cofe.collection.list.EventList<ExecuteMonitor>	getTasks()
ThFilters	getThFilters()
protected Map	getThFiltersStore()
boolean	hasListener(ScriptListener<String> listener)
boolean	isEnginesCaching()
boolean	isRunning()
void	listenScnForSave(String id, ClassLoaderBuilder clb)
void	listenScnForSave(String engineId, Engine engine)
String	nameOf(ClassLoaderBuilder clb)
String	nameOf(Engine en) Возвращает имя под которым зарегистрирован движок
protected void	onStart()
protected void	onStop()
void	removeAllScriptListeners()
void	removeScriptListener(ScriptListener<String> listener)
void	setBindings(EngineBindings bindings)

Methods inherited from class xyz.cofe.cxconsole.srvc.StartableService

fireStarted, fireStarting, fireStopped, fireStopping, getServiceByStopper, getServiceDependencies, isDetectCycleStart, isDetectCycleStop, onResolvedDependencies, start, stop, stopByDependency

Methods inherited from class xyz.cofe.cxconsole.srvc.AbstractService

addServiceEvent, addServiceListener, addServiceListener, findFirstService, findFirstService, findServices, findServices, findServices, fireServiceEvent, fireServiceEvents, getConsole, getFieldDependencies, getInitDependenciesCallCount, getServiceListeners, getUnresolvedDependencies, hasServiceListener, init, initDependencies, instances, isResolvedDependencies, listeners, onInitServicesEnd, removeServiceListener, resolveDependecy

Methods inherited from class java.lang.Object

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

Methods inherited from interface xyz.cofe.cxconsole.ConsoleService

init

Methods inherited from interface xyz.cofe.cxconsole.srvc.ServiceEventPublisher

addServiceEvent, addServiceListener, addServiceListener, fireServiceEvents, getServiceListeners, hasServiceListener, removeServiceListener

Field Detail

running

protected volatile boolean running

scriptEventSender

protected final ScriptEventSupport<String> scriptEventSender

classLoaderBuilders

protected volatile EventMap<String,ClassLoaderBuilder> classLoaderBuilders

classLoadersCache

protected final WeakHashMap<ClassLoaderBuilder,xyz.cofe.cxconsole.script.ScriptService.CLB2B> classLoadersCache

enginesCaching

protected volatile boolean enginesCaching

thFilters

protected ThFilters thFilters

bindings

protected volatile EngineBindings bindings

Constructor Detail

ScriptService

public ScriptService()

Method Detail

getMapDB2Service

public MapDB2Service getMapDB2Service()

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StartService

onStart

protected void onStart()

Specified by:

onStart in class StartableService

onStop

protected void onStop()

Specified by:

onStop in class StartableService

getScriptEventSender

public ScriptEventSupport<String> getScriptEventSender()

hasListener

public boolean hasListener(ScriptListener<String> listener)

Specified by:

hasListener in interface ScriptEventSender<String>

getScriptListeners

public Set<ScriptListener<String>> getScriptListeners()

Specified by:

getScriptListeners in interface ScriptEventSender<String>

addScriptListener

public Closeable addScriptListener(ScriptListener<String> listener)

Specified by:

addScriptListener in interface ScriptEventSender<String>

addScriptListener

public Closeable addScriptListener(ScriptListener<String> listener,
                                   boolean weakLink)

Specified by:

addScriptListener in interface ScriptEventSender<String>

removeScriptListener

public void removeScriptListener(ScriptListener<String> listener)

Specified by:

removeScriptListener in interface ScriptEventSender<String>

removeAllScriptListeners

public void removeAllScriptListeners()

Specified by:

removeAllScriptListeners in interface ScriptEventSender<String>

fireScriptEvent

public void fireScriptEvent(ScriptEvent<String> event)

Specified by:

fireScriptEvent in interface ScriptEventSender<String>

getScriptEventQueue

public Queue<ScriptEvent<String>> getScriptEventQueue()

Specified by:

getScriptEventQueue in interface ScriptEventSender<String>

addScriptEvent

public void addScriptEvent(ScriptEvent<String> ev)

Specified by:

addScriptEvent in interface ScriptEventSender<String>

fireScriptEvents

public void fireScriptEvents()

Specified by:

fireScriptEvents in interface ScriptEventSender<String>

getClassLoaderFactories

public EventMap<String,ClassLoaderFactory> getClassLoaderFactories()

getClassLoaderBuilders

public EventMap<String,ClassLoaderBuilder> getClassLoaderBuilders()

listenScnForSave

public void listenScnForSave(String id,
                             ClassLoaderBuilder clb)

getEngine2ClassLoaderMap

public Map<String,String> getEngine2ClassLoaderMap()

Соответствие имя движка => имя загрузчика (classLoaderBuilder)

Returns:

имя загрузчика

classLoader4engine

public ClassLoader classLoader4engine(String engineId)

nameOf

public String nameOf(ClassLoaderBuilder clb)

getEngineFactories

public EventMap<String,EngineFactory> getEngineFactories()

Фабрики движков

Returns:

фабрики

enginesStoreMap

public org.mapdb.HTreeMap<String,Engine> enginesStoreMap()

listenScnForSave

public void listenScnForSave(String engineId,
                             Engine engine)

getEngines

public EventMap<String,Engine> getEngines()

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

Returns:

карта имя - движок (экземпляр)

nameOf

public String nameOf(Engine en)

Возвращает имя под которым зарегистрирован движок

Parameters:

en - Движок

Returns:

Имя или null

cache

public void cache(String id,
                  Engine en)

isEnginesCaching

public boolean isEnginesCaching()

getThFiltersStore

protected Map getThFiltersStore()

getThFilters

public ThFilters getThFilters()

createThreadMonitor

public <Script> ThreadMonitorImpl<Script> createThreadMonitor(Script script,
                                                              xyz.cofe.collection.Func0<xyz.cofe.collection.Pair<Object,Throwable>> run)

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

Type Parameters:

Script - Тип скрипта

Parameters:

script - Выполняемый скрипт

run - Функция выполнения скрипта, возвращает Pair<Результат,Ошибка скрипта>

Returns:

монитор скрипта

getTasks

public xyz.cofe.collection.list.EventList<ExecuteMonitor> getTasks()

cleanupExecutedTasks

public void cleanupExecutedTasks(long timeout)

getBindings

public EngineBindings getBindings()

setBindings

public void setBindings(EngineBindings bindings)