From 4bcd3b16da0eb0f0efe4fb5eb1e8c6bea9e79cf2 Mon Sep 17 00:00:00 2001 From: Santo Cariotti Date: Wed, 1 Dec 2021 23:48:05 +0100 Subject: tsdwl: adds in java --- Year_3/TSDWL/ex_20131219/MainThread.java | 17 +++++++++++++++++ Year_3/TSDWL/ex_20131219/Shared.java | 10 ++++++++++ Year_3/TSDWL/ex_20131219/Thread1.java | 31 +++++++++++++++++++++++++++++++ Year_3/TSDWL/ex_20131219/Thread2.java | 31 +++++++++++++++++++++++++++++++ 4 files changed, 89 insertions(+) create mode 100644 Year_3/TSDWL/ex_20131219/MainThread.java create mode 100644 Year_3/TSDWL/ex_20131219/Shared.java create mode 100644 Year_3/TSDWL/ex_20131219/Thread1.java create mode 100644 Year_3/TSDWL/ex_20131219/Thread2.java diff --git a/Year_3/TSDWL/ex_20131219/MainThread.java b/Year_3/TSDWL/ex_20131219/MainThread.java new file mode 100644 index 0000000..ea62871 --- /dev/null +++ b/Year_3/TSDWL/ex_20131219/MainThread.java @@ -0,0 +1,17 @@ +public class MainThread { + public static void main(String[] args) { + Shared mem = new Shared(); + Thread1 t1 = new Thread1(mem); + Thread2 t2 = new Thread2(mem); + + t1.start(); + t2.start(); + + try { + t1.join(); + t2.join(); + } catch (InterruptedException e) { + e.printStackTrace(); + } + } +} diff --git a/Year_3/TSDWL/ex_20131219/Shared.java b/Year_3/TSDWL/ex_20131219/Shared.java new file mode 100644 index 0000000..18976c5 --- /dev/null +++ b/Year_3/TSDWL/ex_20131219/Shared.java @@ -0,0 +1,10 @@ +public class Shared { + private int m; + + public Shared() { + m = (int) (Math.random() * (11-1+1)+1); + } + + synchronized public void set(int val) { m = val; } + synchronized public int get() { return m; } +} diff --git a/Year_3/TSDWL/ex_20131219/Thread1.java b/Year_3/TSDWL/ex_20131219/Thread1.java new file mode 100644 index 0000000..b9f8d84 --- /dev/null +++ b/Year_3/TSDWL/ex_20131219/Thread1.java @@ -0,0 +1,31 @@ +public class Thread1 extends Thread { + private Shared mem; + + public Thread1(Shared mem) { + super(); + this.mem = mem; + } + + public void run() { + int xrand; + int m; + while (true) { + synchronized(mem) { + m = mem.get(); + if (m >= 1 && m <= 5) { + xrand = (int) (Math.random() * (10-1+1)+1); + System.out.printf("Thread 1: (%d, %d)\n", m, xrand); + mem.set(xrand); + mem.notifyAll(); + } else { + try { + mem.wait(); + } catch(InterruptedException e) { + e.printStackTrace(); + break; + } + } + } + } + } +} diff --git a/Year_3/TSDWL/ex_20131219/Thread2.java b/Year_3/TSDWL/ex_20131219/Thread2.java new file mode 100644 index 0000000..152e9e0 --- /dev/null +++ b/Year_3/TSDWL/ex_20131219/Thread2.java @@ -0,0 +1,31 @@ +public class Thread2 extends Thread { + private Shared mem; + + public Thread2(Shared mem) { + super(); + this.mem = mem; + } + + public void run() { + int xrand; + int m; + while (true) { + synchronized(mem) { + m = mem.get(); + if (m >= 6 && m <= 10) { + xrand = (int) (Math.random() * (10-1+1)+1); + System.out.printf("\t\t\tThread 2: (%d, %d)\n", m, xrand); + mem.set(xrand); + mem.notifyAll(); + } else { + try { + mem.wait(); + } catch(InterruptedException e) { + e.printStackTrace(); + break; + } + } + } + } + } +} -- cgit v1.2.3-18-g5258