| 1 | public class JavaThread {
 | 
|---|
| 2 |         // Simplistic low-quality Marsaglia Shift-XOR pseudo-random number generator.
 | 
|---|
| 3 |         // Bijective   
 | 
|---|
| 4 |         // Cycle length for non-zero values is 4G-1.
 | 
|---|
| 5 |         // 0 is absorbing and should be avoided -- fixed point.
 | 
|---|
| 6 |         // The returned value is typically masked to produce a positive value.
 | 
|---|
| 7 |         static volatile int Ticket = 0 ; 
 | 
|---|
| 8 | 
 | 
|---|
| 9 |         private static int nextRandom (int x) {
 | 
|---|
| 10 |                 if (x == 0) { 
 | 
|---|
| 11 |                         // reseed the PRNG
 | 
|---|
| 12 |                         // Ticket is accessed infrequently and does not constitute a coherence hot-spot. 
 | 
|---|
| 13 |                         // Note that we use a non-atomic racy increment -- the race is rare and benign. 
 | 
|---|
| 14 |                         // If the race is a concern switch to an AtomicInteger.  
 | 
|---|
| 15 |                         // In addition accesses to the RW volatile global "Ticket"  variable are not 
 | 
|---|
| 16 |                         // (readily) predictable at compile-time so the JIT will not be able to elide 
 | 
|---|
| 17 |                         // nextRandom() invocations.  
 | 
|---|
| 18 |                         x = ++Ticket ; 
 | 
|---|
| 19 |                         if (x == 0) x = 1 ; 
 | 
|---|
| 20 |                 }
 | 
|---|
| 21 |                 x ^= x << 6;
 | 
|---|
| 22 |                 x ^= x >>> 21;
 | 
|---|
| 23 |                 x ^= x << 7;
 | 
|---|
| 24 |                 return x ;   
 | 
|---|
| 25 |         }
 | 
|---|
| 26 |         static int x = 2;
 | 
|---|
| 27 | 
 | 
|---|
| 28 |         static private int times = Integer.parseInt("100000000");
 | 
|---|
| 29 | 
 | 
|---|
| 30 |         public synchronized void noop() {
 | 
|---|
| 31 |                 x = nextRandom( x );
 | 
|---|
| 32 |         }
 | 
|---|
| 33 |         public static void helper() throws InterruptedException {
 | 
|---|
| 34 |                 JavaThread j = new JavaThread();
 | 
|---|
| 35 |                 // Inhibit biased locking ...
 | 
|---|
| 36 |                 x = (j.hashCode() ^ System.identityHashCode(j)) | 1 ;     
 | 
|---|
| 37 |                 for(int i = 1; i <= times; i += 1) {
 | 
|---|
| 38 |                         x = nextRandom(x);
 | 
|---|
| 39 |                         j.noop();
 | 
|---|
| 40 |                 }
 | 
|---|
| 41 |         }
 | 
|---|
| 42 |         public static void InnerMain() throws InterruptedException {
 | 
|---|
| 43 |                 long start = System.nanoTime();
 | 
|---|
| 44 |                 helper();
 | 
|---|
| 45 |                 long end = System.nanoTime();
 | 
|---|
| 46 |                 System.out.println( (end - start) / times );
 | 
|---|
| 47 |         }
 | 
|---|
| 48 |         public static void main(String[] args) throws InterruptedException {
 | 
|---|
| 49 |                 if ( args.length > 2 ) System.exit( 1 );
 | 
|---|
| 50 |                 if ( args.length == 2 ) { times = Integer.parseInt(args[1]); }
 | 
|---|
| 51 | 
 | 
|---|
| 52 |                 for (int n = Integer.parseInt("5"); --n >= 0 ; ) { 
 | 
|---|
| 53 |                         InnerMain();
 | 
|---|
| 54 |                         Thread.sleep(2000);     // 2 seconds
 | 
|---|
| 55 |                         x = nextRandom(x);
 | 
|---|
| 56 |                 }
 | 
|---|
| 57 |                 if ( x == 0 ) System.out.println(x);
 | 
|---|
| 58 |         }
 | 
|---|
| 59 | }
 | 
|---|
| 60 | 
 | 
|---|
| 61 | // Local Variables: //
 | 
|---|
| 62 | // tab-width: 4 //
 | 
|---|
| 63 | // End: //
 | 
|---|