Inheritance diagram for javolution.context.internal.ConcurrentThreadImpl:

Collaboration diagram for javolution.context.internal.ConcurrentThreadImpl:

Public Member Functions
	ConcurrentThreadImpl ()

boolean	execute (Runnable logic, ConcurrentContextImpl inContext)

void	run ()

Private Attributes
ConcurrentContextImpl	context

AtomicBoolean	isBusy = new AtomicBoolean()

Runnable	logic

int	priority

Static Private Attributes
static int	count

Detailed Description

A worker thread executing in a concurrent context.

Definition at line 20 of file ConcurrentThreadImpl.java.

Constructor & Destructor Documentation

◆ ConcurrentThreadImpl()

javolution.context.internal.ConcurrentThreadImpl.ConcurrentThreadImpl ( )

Default constructor.

Definition at line 31 of file ConcurrentThreadImpl.java.

                                   {
         this.setName("ConcurrentThread-" + ++count);
         setDaemon(true);
     }

References javolution.context.internal.ConcurrentThreadImpl.count.

Member Function Documentation

◆ execute()

boolean javolution.context.internal.ConcurrentThreadImpl.execute	(	Runnable	logic,
		ConcurrentContextImpl	inContext
	)

Executes the specified logic by this thread if ready; returns

false

if this thread is busy.

Definition at line 40 of file ConcurrentThreadImpl.java.

                                                                             {
         if (!isBusy.compareAndSet(false, true))
             return false;
         synchronized (this) {
             this.priority = Thread.currentThread().getPriority();
             this.context = inContext;
             this.logic = logic;
             this.notify();
         }
         return true;
     }

References javolution.context.internal.ConcurrentThreadImpl.isBusy, and javolution.context.internal.ConcurrentThreadImpl.logic.

◆ run()

void javolution.context.internal.ConcurrentThreadImpl.run ( )

Definition at line 53 of file ConcurrentThreadImpl.java.

                       {
         while (true) { // Main loop.
             try {
                 synchronized (this) {
                     while (logic == null) this.wait();
                 }
                 this.setPriority(priority);
                 AbstractContext.inherit(context);
                 logic.run();
                 context.completed(null);
             } catch (Throwable error) {
                 context.completed(error);
             }
             // Clean up.
             logic = null;
             context = null;
             AbstractContext.inherit(null);
             isBusy.set(false);
         }
     }