From 6274bebf7060bd6be19e4b17bd4f754f9718c771 Mon Sep 17 00:00:00 2001 From: Claudio Maggioni Date: Mon, 2 Jan 2023 15:18:34 +0100 Subject: [PATCH] dislproj: ex2 done --- .../src-profiler/ex2/Instrumentation.java | 39 +++++++++++++++++++ .../ex2/IsNotTriviallyThreadGuard.java | 12 ++++++ .../ex2/IsTriviallyThreadGuard.java | 12 ++++++ .../src-profiler/ex2/Profiler.java | 38 ++++++++++++++++++ 4 files changed, 101 insertions(+) create mode 100644 DiSLProject2022/src-profiler/ex2/IsNotTriviallyThreadGuard.java create mode 100644 DiSLProject2022/src-profiler/ex2/IsTriviallyThreadGuard.java create mode 100644 DiSLProject2022/src-profiler/ex2/Profiler.java diff --git a/DiSLProject2022/src-profiler/ex2/Instrumentation.java b/DiSLProject2022/src-profiler/ex2/Instrumentation.java index 9811186..b79e493 100644 --- a/DiSLProject2022/src-profiler/ex2/Instrumentation.java +++ b/DiSLProject2022/src-profiler/ex2/Instrumentation.java @@ -1,4 +1,43 @@ package ex2; +import ch.usi.dag.disl.annotation.After; +import ch.usi.dag.disl.annotation.Before; +import ch.usi.dag.disl.annotation.ThreadLocal; +import ch.usi.dag.disl.dynamiccontext.DynamicContext; +import ch.usi.dag.disl.marker.BodyMarker; +import ch.usi.dag.disl.marker.BytecodeMarker; + public class Instrumentation { + + @ThreadLocal + static long readCount; + + @ThreadLocal + static long writeCount; + + @Before(marker = BytecodeMarker.class, args = "getfield") + static void beforeGetField() { + readCount++; + } + + @Before(marker = BytecodeMarker.class, args = "putfield") + static void beforePutField() { + writeCount++; + } + + @After(marker = BodyMarker.class, + scope = "void run()", + guard = IsTriviallyThreadGuard.class) + static void onThreadExit() { + Profiler.increment(readCount, writeCount); + } + + @After(marker = BodyMarker.class, + scope = "void run()", + guard = IsNotTriviallyThreadGuard.class) + static void onThreadExit(final DynamicContext dc) { + if (Profiler.isThread(dc.getThis().getClass())) { + Profiler.increment(readCount, writeCount); + } + } } diff --git a/DiSLProject2022/src-profiler/ex2/IsNotTriviallyThreadGuard.java b/DiSLProject2022/src-profiler/ex2/IsNotTriviallyThreadGuard.java new file mode 100644 index 0000000..df6bc7a --- /dev/null +++ b/DiSLProject2022/src-profiler/ex2/IsNotTriviallyThreadGuard.java @@ -0,0 +1,12 @@ +package ex2; + +import ch.usi.dag.disl.annotation.GuardMethod; +import ch.usi.dag.disl.staticcontext.ClassStaticContext; + +public class IsNotTriviallyThreadGuard { + + @GuardMethod + public static boolean isNotTriviallyThread(final ClassStaticContext csc) { + return !IsTriviallyThreadGuard.isThread(csc); + } +} diff --git a/DiSLProject2022/src-profiler/ex2/IsTriviallyThreadGuard.java b/DiSLProject2022/src-profiler/ex2/IsTriviallyThreadGuard.java new file mode 100644 index 0000000..15c8d36 --- /dev/null +++ b/DiSLProject2022/src-profiler/ex2/IsTriviallyThreadGuard.java @@ -0,0 +1,12 @@ +package ex2; + +import ch.usi.dag.disl.annotation.GuardMethod; +import ch.usi.dag.disl.staticcontext.ClassStaticContext; + +public class IsTriviallyThreadGuard { + @GuardMethod + public static boolean isThread(ClassStaticContext csc) { + return csc.getInternalName().equals("java/lang/Thread") || + csc.getSuperClassInternalName().equals("java/lang/Thread"); + } +} diff --git a/DiSLProject2022/src-profiler/ex2/Profiler.java b/DiSLProject2022/src-profiler/ex2/Profiler.java new file mode 100644 index 0000000..2ffe95e --- /dev/null +++ b/DiSLProject2022/src-profiler/ex2/Profiler.java @@ -0,0 +1,38 @@ +package ex2; + +import java.util.HashMap; +import java.util.Map; +import java.util.concurrent.atomic.LongAdder; + +public final class Profiler { + + // not concurrent on purpose, since the value of the map is computed with a pure function + // on the map key, and thus we don't care if the value is overwritten as a result of a + // race condition + private static final Map, Boolean> isThread = new HashMap<>(); + + private static final LongAdder reads = new LongAdder(); + + private static final LongAdder writes = new LongAdder(); + + static { + Runtime.getRuntime().addShutdownHook(new Thread(() -> { + System.out.printf("Instance field read access: %d\nInstance field write access: %d\n", + reads.longValue(), + writes.longValue()); + })); + } + + private Profiler() { + } + + public static boolean isThread(final Class clazz) { + return isThread.computeIfAbsent(clazz, Thread.class::isAssignableFrom); + } + + public static void increment(long readCount, long writeCount) { + reads.add(readCount); + writes.add(writeCount); + } + +}