Subversion Repository Public Repository

litesoft

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
package org.litesoft.core.delayed.nonpublic;

import org.litesoft.core.delayed.*;
import org.litesoft.core.util.*;

public class DoubleLinkedListTimedRunnableNode
{
    private DoubleLinkedListTimedRunnableNode mPrev = null;
    private DoubleLinkedListTimedRunnableNode mNext = null;
    private long mRunWhen;
    private TimedRunnable mTimedRunnable;

    private DoubleLinkedListTimedRunnableNode( long pRunWhen, TimedRunnable pTimedRunnable )
    {
        mRunWhen = pRunWhen;
        UtilsCommon.assertNotNull( "TimedRunnable", mTimedRunnable = pTimedRunnable );
    }

    public long getRunWhen()
    {
        return mRunWhen;
    }

    public TimedRunnable getTimedRunnable()
    {
        return mTimedRunnable;
    }

    /**
     * Remove 'this' from DoubleLinkList
     *
     * @return mNext
     */
    public DoubleLinkedListTimedRunnableNode remove()
    {
        // x - this - y
        DoubleLinkedListTimedRunnableNode rv = this.mNext;
        if ( this.mPrev != null )
        {
            mPrev.mNext = this.mNext;
        }
        if ( this.mNext != null )
        {
            mNext.mPrev = this.mPrev;
        }
        mPrev = mNext = null;
        // x - y
        return rv;
    }

    private boolean isBefore( DoubleLinkedListTimedRunnableNode pTimerNode )
    {
        return (pTimerNode != null) && (this.mRunWhen < pTimerNode.mRunWhen);
    }

    /**
     * Insert 'pNewTimerNode' before 'this' in the LinkList
     *
     * @param pNewTimerNode may NOT have its links set
     *
     * @return pNewTimerNode
     */
    private DoubleLinkedListTimedRunnableNode insertBeforeMe( DoubleLinkedListTimedRunnableNode pNewTimerNode )
    {
        // x - this - y
        if ( chk( pNewTimerNode ) )
        {
            pNewTimerNode.mNext = this;
            pNewTimerNode.mPrev = this.mPrev;
            if ( this.mPrev != null )
            {
                this.mPrev.mNext = pNewTimerNode;
            }
            this.mPrev = pNewTimerNode;
        }
        // x - pNewTimerNode - this - y
        return pNewTimerNode;
    }

    /**
     * Insert 'pNewTimerNode' after 'this' in the LinkList
     *
     * @param pNewTimerNode may NOT have its links set
     */
    private void insertAfterMe( DoubleLinkedListTimedRunnableNode pNewTimerNode )
    {
        // x - this - y
        if ( chk( pNewTimerNode ) )
        {
            pNewTimerNode.mNext = this.mNext;
            if ( this.mNext != null )
            {
                this.mNext.mPrev = pNewTimerNode;
            }
            this.mNext = pNewTimerNode;
            pNewTimerNode.mPrev = this;
        }
        // x - this - pNewTimerNode - y
    }

    private boolean chk( DoubleLinkedListTimedRunnableNode pNewTimerNode )
    {
        if ( pNewTimerNode == null )
        {
            return false;
        }
        if ( (pNewTimerNode.mPrev != null) || (pNewTimerNode.mNext != null) )
        {
            throw new IllegalArgumentException( "NewTimerNode has non-Null links" );
        }
        return true;
    }

    /**
     * @return the New Head
     */
    public static DoubleLinkedListTimedRunnableNode addTo( DoubleLinkedListTimedRunnableNode pCurrent,
                                                           long pRunWhen, TimedRunnable pTimedRunnable )
    {
        if ( pTimedRunnable != null )
        {
            DoubleLinkedListTimedRunnableNode zNewNode =
                    new DoubleLinkedListTimedRunnableNode( pRunWhen, pTimedRunnable );
            if ( pCurrent == null )
            {
                return zNewNode;
            }
            if ( zNewNode.isBefore( pCurrent ) )
            {
                return pCurrent.insertBeforeMe( zNewNode );
            }
            DoubleLinkedListTimedRunnableNode cur = pCurrent;
            while ( cur.mNext != null )
            {
                cur = cur.mNext;
                if ( zNewNode.isBefore( cur ) )
                {
                    cur.insertBeforeMe( zNewNode );
                    return pCurrent;
                }
            }
            cur.insertAfterMe( zNewNode );
        }
        return pCurrent;
    }

    public static DoubleLinkedListTimedRunnableNode locate( DoubleLinkedListTimedRunnableNode pCurrent,
                                                            TimedRunnable pTimedRunnable )
    {
        if ( pTimedRunnable != null )
        {
            while ( pCurrent != null )
            {
                if ( pTimedRunnable == pCurrent.mTimedRunnable )
                {
                    return pCurrent;
                }
                pCurrent = pCurrent.mNext;
            }
        }
        return null;
    }
}

Commits for litesoft/trunk/Java/core/Anywhere/src/org/litesoft/core/delayed/nonpublic/DoubleLinkedListTimedRunnableNode.java

Diff revisions: vs.
Revision Author Commited Message
2 GeorgeS picture GeorgeS Sun 07 Feb, 2010 12:50:58 +0000