com.fr.third.jgroups.protocols

类 SCOPE.QueueThread

java.lang.Object

com.fr.third.jgroups.protocols.SCOPE.QueueThread

所有已实现的接口:

java.lang.Runnable

封闭类:

SCOPE

protected class SCOPE.QueueThread
extends java.lang.Object
implements java.lang.Runnable

字段概要

字段

限定符和类型	字段和说明
protected boolean	first
protected SCOPE.MessageQueue	queue

构造器概要

构造器

构造器和说明
SCOPE.QueueThread(SCOPE.MessageQueue queue)

方法概要

方法

限定符和类型	方法和说明
void	run() Try to remove as many messages as possible from the queue and pass them up.

从类继承的方法 java.lang.Object

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

字段详细资料

queue

protected final SCOPE.MessageQueue queue

first

protected boolean first

构造器详细资料

SCOPE.QueueThread

public SCOPE.QueueThread(SCOPE.MessageQueue queue)

方法详细资料

run

public void run()

Try to remove as many messages as possible from the queue and pass them up. The outer and inner loop and the size() check at the end prevent the following scenario:

 - Threads T1 and T2
 - T1 has the CAS
 - T1: remove() == null
 - T2: add()
 - T2: attempt to set the CAS: false, return
 - T1: set the CAS to false, return
 ==> Result: we have a message in the queue that nobody takes care of !
 

指定者:

run 在接口中 java.lang.Runnable