org.freedesktop.dbus.EfficientQueue クラス

org.freedesktop.dbus.EfficientQueue 連携図

公開メンバ関数
	EfficientQueue (int initial_size)
Message []	getKeys ()
void	add (Message m)
Message	remove ()
boolean	isEmpty ()
int	size ()

非公開メンバ関数
void	grow ()
void	shrink ()

非公開変数類
Message []	mv
int	start
int	end
int	init_size

詳解

Provides a Message queue which doesn't allocate objects on insertion/removal.

構築子と解体子

EfficientQueue()

org.freedesktop.dbus.EfficientQueue.EfficientQueue ( int  initial_size )

inline

                                            {
        init_size = initial_size;
        shrink();
    }

関数詳解

add()

void org.freedesktop.dbus.EfficientQueue.add ( Message  m )

inline

                               {
        if (Debug.debug) Debug.print(Debug.DEBUG, "Enqueueing Message " + m);
        // put this at the end
        mv[end] = m;
        // move the end
        if (end == (mv.length - 1)) end = 0;
        else end++;
        // if we are out of space, grow.
        if (end == start) grow();
    }

getKeys()

Message [] org.freedesktop.dbus.EfficientQueue.getKeys ( )

inline

                               {
        if (start == end) return new Message[0];
        Message[] lv;
        if (start < end) {
            int size = end - start;
            lv = new Message[size];
            System.arraycopy(mv, start, lv, 0, size);
        } else {
            int size = mv.length - start + end;
            lv = new Message[size];
            System.arraycopy(mv, start, lv, 0, mv.length - start);
            System.arraycopy(mv, 0, lv, mv.length - start, end);
        }
        return lv;
    }

grow()

void org.freedesktop.dbus.EfficientQueue.grow ( )

inlineprivate

                        {
        if (Debug.debug) Debug.print(Debug.DEBUG, "Growing");
        // create new vectors twice as long
        Message[] oldmv = mv;
        mv = new Message[oldmv.length * 2];

        // copy start->length to the start of the new vector
        System.arraycopy(oldmv, start, mv, 0, oldmv.length - start);
        // copy 0->end to the next part of the new vector
        if (end != (oldmv.length - 1)) {
            System.arraycopy(oldmv, 0, mv, oldmv.length - start, end + 1);
        }
        // reposition pointers
        start = 0;
        end = oldmv.length;
    }

isEmpty()

boolean org.freedesktop.dbus.EfficientQueue.isEmpty ( )

inline

                             {
        // check if find succeeds
        return start == end;
    }

remove()

Message org.freedesktop.dbus.EfficientQueue.remove ( )

inline

                            {
        if (start == end) return null;
        // find the item
        int pos = start;
        // get the value
        Message m = mv[pos];
        // set it as unused
        mv[pos] = null;
        if (start == (mv.length - 1)) start = 0;
        else start++;
        if (Debug.debug) Debug.print(Debug.DEBUG, "Dequeueing " + m);
        return m;
    }

shrink()

void org.freedesktop.dbus.EfficientQueue.shrink ( )

inlineprivate

                          {
        if (Debug.debug) Debug.print(Debug.DEBUG, "Shrinking");
        if (null != mv && mv.length == init_size) return;
        // reset to original size
        mv = new Message[init_size];
        start = 0;
        end = 0;
    }

size()

int org.freedesktop.dbus.EfficientQueue.size ( )

inline

                      {
        if (end >= start)
            return end - start;
        else
            return mv.length - start + end;
    }

メンバ詳解

end

int org.freedesktop.dbus.EfficientQueue.end

private

init_size

int org.freedesktop.dbus.EfficientQueue.init_size

private

mv

Message [] org.freedesktop.dbus.EfficientQueue.mv

private

start

int org.freedesktop.dbus.EfficientQueue.start

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/federation/src/federation/sssd/src/main/java/org/freedesktop/dbus/EfficientQueue.java