Changeset 578 for Tests

Timestamp:

02/03/13 21:22:14 (9 years ago)

Author:

BegemoT

Message:

 

File:

• Tests/JAVA/test/src/main/java/test/threads/experiment2/Main.java (modified) (6 diffs)

Tests/JAVA/test/src/main/java/test/threads/experiment2/Main.java

@@ -18 +18 @@
 public class Main {
         private static final boolean ASYNC = Boolean.getBoolean( "async" );
-        private static final boolean PREDICABLE_SCAN = Boolean.getBoolean( "predictable" );
+        private static final boolean PREDICTABLE_SCAN = Boolean.getBoolean( "predictable" );
 
         private static final int RUNS = Integer.getInteger( "runs", 32 );
         private static final int TURNS = Integer.getInteger( "turns", 1 << 20 );
 
-        private static final int REPOSITORY_SIZE_EXP = Integer.getInteger( "repository-size-exp", 15 );
-        private static final int REPOSITORY_SIZE = 1 << REPOSITORY_SIZE_EXP;
-        private static final int READ_PER_MESSAGE = 128;
-        private static final int READ_STEP = 1025;
+        private static final int DATA_SIZE_EXP = Integer.getInteger( "data-size-exp", 12 );
+        private static final int DATA_SIZE = 1 << DATA_SIZE_EXP;
+
+
+        private static final int OPS_PER_MESSAGE = 128;
+        private static final int OPS_ARRAY_STEP = 8;
 
         private static final ThreadAffinityService AFFINITY_SERVICE = ThreadAffinityUtils.defaultAffinityService();
@@ -33 +35 @@
         public static void main( final String[] args ) {
                 System.out.printf(
-                                "%s, Repo: double[%d], %d reads/msg, %s\n" +
+                                "%s, data: double[%d], %d reads/msg, %s\n" +
                                                 "\t%d runs by %d messages each\n",
                                 ( ASYNC ? "ASYNC" : "SYNC" ),
-                                REPOSITORY_SIZE, READ_PER_MESSAGE,
-                                PREDICABLE_SCAN ? "step: " + READ_STEP : "random",
+                                DATA_SIZE, OPS_PER_MESSAGE,
+                                PREDICTABLE_SCAN ? "step: " + OPS_ARRAY_STEP : "random",
                                 RUNS, TURNS
                 );
 
 
-                final double[] repositoryA = new double[REPOSITORY_SIZE];
-                Arrays.fill( repositoryA, 1.0 );
-                final double[] repositoryB = new double[REPOSITORY_SIZE];
-                Arrays.fill( repositoryB, 1.0 );
-
-
-                final Phase a = new Phase( repositoryA );
-                final Phase b = new Phase( repositoryB );
+                final double[] dataA = new double[DATA_SIZE];
+                Arrays.fill( dataA, 1.0 );
+                final double[] dataB = new double[DATA_SIZE];
+                Arrays.fill( dataB, 1.0 );
+
+
+                final Phase a = new Phase( dataA );
+                final Phase b = new Phase( dataB );
 
                 final Function<Message, Message> function;
@@ -86 +88 @@
         }
 
-        private static void putStressOnMemory( final double[] repository,
+        private static void putStressOnMemory( final double[] array,
                                                final int offset,
                                                final double amount ) {
-                if( PREDICABLE_SCAN ) {
-                        for( int i = 0; i < READ_PER_MESSAGE; i++ ) {
-                                final int index = ( i * READ_STEP + offset ) % REPOSITORY_SIZE;
-                                repository[index] += amount;
+                if( PREDICTABLE_SCAN ) {
+                        for( int i = 0; i < OPS_PER_MESSAGE; i++ ) {
+                                final int index = ( i * OPS_ARRAY_STEP + offset ) % DATA_SIZE;
+                                array[index] += amount;
                         }
                 } else {
                         int index = offset;
-                        for( int i = 0; i < READ_PER_MESSAGE; i++ ) {
-                                index = Math.abs( index * offset ) % REPOSITORY_SIZE;
-                                repository[index] += amount;
+                        for( int i = 0; i < OPS_PER_MESSAGE; i++ ) {
+                                index = Math.abs( index * offset ) % DATA_SIZE;
+                                array[index] += amount;
                         }
                 }
@@ -128 +130 @@
                 final double amountStep = 1.0 / turns;
                 for( int turn = 0; turn < turns; turn++ ) {
-                        message.index = ( message.index + 1 ) / REPOSITORY_SIZE;
+                        message.index = ( message.index + 1 ) / DATA_SIZE;
                         message.amount += amountStep;
                         f.apply( message );
@@ -173 +175 @@
         public static class Phase implements Function<Message, Message> {
 
-                private final double[] repository;
-
-                public Phase( final double[] repository ) {
-                        this.repository = repository;
+                private final double[] data;
+
+                public Phase( final double[] data ) {
+                        this.data = data;
                 }
 
@@ -183 +185 @@
                         final double amount = message.amount;
                         final int offset = message.index;
-                        putStressOnMemory( repository, offset, amount );
+                        putStressOnMemory( data, offset, amount );
                         //actually, message just pass through
                         return message;