Changeset 56de6b39 for src

Timestamp:

Nov 27, 2017, 4:17:12 PM (7 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

8a78dd3

Parents:

a6d70cd

Message:

Updated java signal benchmarks more closely mirror cfa/uC++ benchmarks

Location:

src/benchmark

Files:

• Makefile.am (modified) (1 diff)
• schedint/JavaThread.java (modified) (1 diff)

src/benchmark/Makefile.am

@@ -165 +165 @@
         signal-cfa1.run         \
         signal-cfa2.run         \
-        signal-cfa4.run
+        signal-cfa4.run         \
+        signal-java_thread.run
 
 signal-upp$(EXEEXT):

src/benchmark/schedint/JavaThread.java

@@ -1 @@
-import java.util.concurrent.atomic.AtomicBoolean;
+class Monitor {
+        public static volatile Boolean go = false;
+}
 
-public class JavaThread {
-        public synchronized void doWait  () throws InterruptedException { this.wait  (); }
-        public synchronized void doSignal() throws InterruptedException { this.notify(); }
+class Signaller extends Thread {
+        Monitor m;
+        Signaller(Monitor m) {
+                this.m = m;
+        }
 
-        public static AtomicBoolean go = new AtomicBoolean( false );
-
-        public static class Signaller extends Thread {
-                JavaThread j;
-                Signaller(JavaThread j) {
-                        this.j = j;
-                }
-
-                public void run() {
-                        go.set( true );
-                        try {
-                                while( JavaThread.go.get() ) {
-                                        this.j.doSignal();
-                                }
-                        } catch(InterruptedException trash) {
-
+        public void run() {
+                Monitor.go = true;
+                while( Monitor.go ) {
+                        synchronized(this.m) {
+                                this.m.notify();
                         }
                 }
         }
+}
 
+public class JavaThread {
         public static void main(String[] args) throws InterruptedException {
                 int NoOfTimes = 50000;
-                JavaThread j = new JavaThread();
-                Signaller s = new Signaller(j);
-                s.start();
-                while( !JavaThread.go.get() ) {
-                        Thread.yield();
+                Monitor m = new Monitor();
+                long start, end;
+                Signaller s = new Signaller(m);
+                synchronized(m) {
+                        s.start();
+                        while( !Monitor.go ) {
+                                Thread.yield();
+                        }
+                        start = System.nanoTime();
+                        for(int i = 1; i <= NoOfTimes; i += 1) {
+                                m.wait();
+                        }
+                        end = System.nanoTime();
                 }
-                long start = System.nanoTime();
-                for(int i = 1; i <= NoOfTimes; i += 1) {
-                        j.doWait();
-                }
-                long end = System.nanoTime();
-                go.set( false );
+                Monitor.go = false;
                 s.join();
                 System.out.println( (end - start) / NoOfTimes);