WS08' #1
@@ -21,7 +21,14 @@ public class DeadlockPreventionWorkshop {
|
|||||||
|
|
||||||
public static void useResources(Resource r1, Resource r2) {
|
public static void useResources(Resource r1, Resource r2) {
|
||||||
// TODO: Prevent deadlock by enforcing a consistent lock acquisition order
|
// TODO: Prevent deadlock by enforcing a consistent lock acquisition order
|
||||||
// Hint: Compare resource IDs and always synchronize on the resource with the smaller ID first.
|
Resource first = r1;
|
||||||
|
Resource second = r2;
|
||||||
|
if (r1.getId() > r2.getId()) {
|
||||||
|
first = r2;
|
||||||
|
second = r1;
|
||||||
|
}
|
||||||
|
r1 = first;
|
||||||
|
r2 = second;
|
||||||
|
|
||||||
System.out.println(Thread.currentThread().getName() + " is attempting to lock " + r1.getName());
|
System.out.println(Thread.currentThread().getName() + " is attempting to lock " + r1.getName());
|
||||||
synchronized (r1) {
|
synchronized (r1) {
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ public class LockWorkshop {
|
|||||||
public static int counter = 0;
|
public static int counter = 0;
|
||||||
|
|
||||||
// TODO: Create a ReentrantLock instance to protect the critical section
|
// TODO: Create a ReentrantLock instance to protect the critical section
|
||||||
|
public static final Lock lock = new ReentrantLock();
|
||||||
|
|
||||||
public static class MyRunnable implements Runnable {
|
public static class MyRunnable implements Runnable {
|
||||||
@Override
|
@Override
|
||||||
@@ -14,8 +15,13 @@ public class LockWorkshop {
|
|||||||
int i;
|
int i;
|
||||||
for (i = 0; i < 1_000_000; i++) {
|
for (i = 0; i < 1_000_000; i++) {
|
||||||
// TODO: Acquire the lock, increment the counter, and release the lock safely in a finally block
|
// TODO: Acquire the lock, increment the counter, and release the lock safely in a finally block
|
||||||
|
lock.lock();
|
||||||
|
try {
|
||||||
counter += 1;
|
counter += 1;
|
||||||
|
} finally {
|
||||||
|
lock.unlock();
|
||||||
}
|
}
|
||||||
|
|
||||||
System.out.println("Increments completed by " + Thread.currentThread().getName() + ": " + i);
|
System.out.println("Increments completed by " + Thread.currentThread().getName() + ": " + i);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -34,4 +40,5 @@ public class LockWorkshop {
|
|||||||
|
|
||||||
System.out.println("Final counter value (expected 2000000): " + counter);
|
System.out.println("Final counter value (expected 2000000): " + counter);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ public class SynchronizedWorkshop {
|
|||||||
public static int counter = 0;
|
public static int counter = 0;
|
||||||
|
|
||||||
// TODO: Define a lock object to prevent race condition
|
// TODO: Define a lock object to prevent race condition
|
||||||
|
public static final Object lock = new Object();
|
||||||
|
|
||||||
public static class MyRunnable implements Runnable {
|
public static class MyRunnable implements Runnable {
|
||||||
@Override
|
@Override
|
||||||
@@ -11,6 +12,7 @@ public class SynchronizedWorkshop {
|
|||||||
int i;
|
int i;
|
||||||
for (i = 0; i < 1_000_000; i++) {
|
for (i = 0; i < 1_000_000; i++) {
|
||||||
// TODO: Use a synchronized block to protect the counter increment
|
// TODO: Use a synchronized block to protect the counter increment
|
||||||
|
synchronized (lock) {
|
||||||
counter += 1;
|
counter += 1;
|
||||||
}
|
}
|
||||||
System.out.println("Increments completed by " + Thread.currentThread().getName() + ": " + i);
|
System.out.println("Increments completed by " + Thread.currentThread().getName() + ": " + i);
|
||||||
@@ -31,4 +33,5 @@ public class SynchronizedWorkshop {
|
|||||||
|
|
||||||
System.out.println("Final counter value (expected 2000000): " + counter);
|
System.out.println("Final counter value (expected 2000000): " + counter);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -22,19 +22,31 @@ public class TaylorSeries {
|
|||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
// TODO: Calculate the n-th term of the Taylor series for sin(x):
|
// TODO: Calculate the n-th term of the Taylor series for sin(x):
|
||||||
// term = (-1)^n * (x^(2n+1)) / (2n+1)!
|
BigDecimal numerator = x.pow(2 * n + 1, mc);
|
||||||
// Add the term to the global sum ensuring thread-safety.
|
BigDecimal denominator = factorial(2 * n + 1);
|
||||||
|
|
||||||
|
BigDecimal term = numerator.divide(denominator, mc);
|
||||||
|
|
||||||
|
if (n % 2 != 0) {
|
||||||
|
term = term.negate();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
synchronized (TaylorSeries.class) {
|
||||||
|
sum = sum.add(term, mc);
|
||||||
|
}
|
||||||
|
}
|
||||||
// TODO: Implement factorial(k) using BigDecimal
|
// TODO: Implement factorial(k) using BigDecimal
|
||||||
private BigDecimal factorial(int k) {
|
private BigDecimal factorial(int k) {
|
||||||
return BigDecimal.ZERO;
|
BigDecimal result = BigDecimal.ONE;
|
||||||
|
for (int i = 2; i <= k; i++) {
|
||||||
|
result = result.multiply(BigDecimal.valueOf(i));
|
||||||
|
}
|
||||||
|
return result;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static BigDecimal sum = BigDecimal.ZERO;
|
public static BigDecimal sum = BigDecimal.ZERO;
|
||||||
|
|
||||||
public static void main(String[] args) {
|
public static void main (String[]args){
|
||||||
ExecutorService threadPool = Executors.newFixedThreadPool(4);
|
ExecutorService threadPool = Executors.newFixedThreadPool(4);
|
||||||
sum = BigDecimal.ZERO;
|
sum = BigDecimal.ZERO;
|
||||||
BigDecimal x = new BigDecimal("0.01");
|
BigDecimal x = new BigDecimal("0.01");
|
||||||
@@ -42,6 +54,7 @@ public class TaylorSeries {
|
|||||||
// Submit tasks to calculate terms
|
// Submit tasks to calculate terms
|
||||||
for (int i = 0; i < 100; i++) {
|
for (int i = 0; i < 100; i++) {
|
||||||
// TODO: Submit task to the thread pool
|
// TODO: Submit task to the thread pool
|
||||||
|
threadPool.submit(new CalculateSin(x, i));
|
||||||
}
|
}
|
||||||
|
|
||||||
threadPool.shutdown();
|
threadPool.shutdown();
|
||||||
@@ -72,4 +85,4 @@ public class TaylorSeries {
|
|||||||
System.out.println("Accurate Value: " + accurateValue.toPlainString());
|
System.out.println("Accurate Value: " + accurateValue.toPlainString());
|
||||||
System.out.println("Difference: " + accurateValue.subtract(sum).abs().toPlainString());
|
System.out.println("Difference: " + accurateValue.subtract(sum).abs().toPlainString());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user