Package org.apache.felix.cm.impl

Class UpdateThread

java.lang.Object

org.apache.felix.cm.impl.UpdateThread

All Implemented Interfaces:

Runnable

public class UpdateThread
extends Object
implements Runnable

The UpdateThread is the thread used to update managed services and managed service factories as well as to send configuration events.

Field Summary

Fields

Modifier and Type	Field	Description
private final AccessControlContext	acc
private final BlockingDeque<Runnable>	updateTasks
private Thread	worker
private final String	workerBaseName
private final ThreadGroup	workerThreadGroup

Constructor Summary

Constructors

Constructor	Description
UpdateThread(ThreadGroup tg, String name)

Method Summary

Modifier and Type	Method	Description
void	run()
(package private) void	run0(Runnable task)
(package private) void	schedule(Runnable update)
(package private) void	start()	Starts processing the queued tasks.
(package private) void	terminate()	Terminates the worker thread and waits for the thread to have processed all outstanding events up to and including the termination job.

Methods inherited from class java.lang.Object

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

Field Details

workerThreadGroup

private final ThreadGroup workerThreadGroup

workerBaseName

private final String workerBaseName

updateTasks

private final BlockingDeque<Runnable> updateTasks

worker

private volatile Thread worker

acc

private final AccessControlContext acc

Constructor Details

UpdateThread

public UpdateThread(ThreadGroup tg,
 String name)

Method Details

run

public void run()

Specified by:

run in interface Runnable

run0

void run0(Runnable task)
   throws Throwable

Throws:

Throwable

start

void start()

Starts processing the queued tasks. This method does nothing if the worker has already been started.

terminate

void terminate()

Terminates the worker thread and waits for the thread to have processed all outstanding events up to and including the termination job. All jobs scheduled after termination has been initiated will not be processed any more. This method does nothing if the worker thread is not currently active.

If the worker thread does not terminate within 5 seconds it is killed by calling the (deprecated) Thread.stop() method. It may be that the worker thread may be blocked by a deadlock (it should not, though). In this case hope is that Thread.stop() will be able to released that deadlock at the expense of one or more tasks to not be executed any longer.... In any case an ERROR message is logged with the LogService in this situation.

schedule

void schedule(Runnable update)