litesoft
Diff Revisions
49
vs
858
for /trunk/Java/core/Server/src/org/litesoft/delayed/nonpublic/ThreadBasedDelayedTimedRunnableRunner.java
|
@@ -1,21 +1,25 @@ |
1 |
1 |
|
// This Source Code is in the Public Domain per: http://litesoft.org/License.txt |
2 |
2 |
|
package org.litesoft.delayed.nonpublic; |
3 |
3 |
|
|
4 |
|
- |
import java.util.*; |
5 |
|
- |
|
6 |
4 |
|
import org.litesoft.core.delayed.nonpublic.*; |
|
5 |
+ |
import org.litesoft.core.simpletypes.temporal.*; |
7 |
6 |
|
import org.litesoft.core.util.*; |
8 |
7 |
|
|
9 |
8 |
|
public class ThreadBasedDelayedTimedRunnableRunner extends AbstractDelayedTimedRunnableRunner |
10 |
9 |
|
{ |
11 |
10 |
|
private final MyRunnable mMyRunnable; |
12 |
11 |
|
|
13 |
|
- |
public ThreadBasedDelayedTimedRunnableRunner() |
|
12 |
+ |
public ThreadBasedDelayedTimedRunnableRunner( MillisecTimeSource pMillisecTimeSource ) |
14 |
13 |
|
{ |
15 |
|
- |
super( LoggingUnexpectedExceptionHandler.INSTANCE ); |
|
14 |
+ |
super( pMillisecTimeSource, LoggingUnexpectedExceptionHandler.INSTANCE ); |
16 |
15 |
|
mMyRunnable = new MyRunnable(); |
17 |
16 |
|
} |
18 |
17 |
|
|
|
18 |
+ |
public ThreadBasedDelayedTimedRunnableRunner() |
|
19 |
+ |
{ |
|
20 |
+ |
this( null ); |
|
21 |
+ |
} |
|
22 |
+ |
|
19 |
23 |
|
@Override |
20 |
24 |
|
protected void LLscheduleFor( long pWhenTimeInMilliSecs, long pNowInMilliSecs ) |
21 |
25 |
|
{ |
|
@@ -82,7 +86,7 @@ |
82 |
86 |
|
{ |
83 |
87 |
|
wait(); |
84 |
88 |
|
} |
85 |
|
- |
long zNow = new Date().getTime(); |
|
89 |
+ |
long zNow = mMillisecTimeSource.now(); |
86 |
90 |
|
if ( mTillTime <= zNow ) |
87 |
91 |
|
{ |
88 |
92 |
|
mTillTime = null; |