Ttykuu

WiFi Thermostat, No C Terminal on Furnace

Drawing ramified coverings with tikz

Does a 'pending' US visa application constitute a denial?

Lowest total scrabble score

What should you do if you miss a job interview (deliberately)?

What was the exact wording from Ivanhoe of this advice on how to free yourself from slavery?

Is the U.S. Code copyrighted by the Government?

How could a planet have erratic days?

How should I respond when I lied about my education and the company finds out through background check?

What is this called? Old film camera viewer?

How to implement a feedback to keep the DC gain at zero for this conceptual passive filter?

How do you respond to a colleague from another team when they're wrongly expecting that you'll help them?

Fear of getting stuck on one programming language / technology that is not used in my country

How to indicate a cut out for a product window

What should you do when eye contact makes your subordinate uncomfortable?

Where does the bonus feat in the cleric starting package come from?

Redundant comparison & "if" before assignment

What is the evidence for the "tyranny of the majority problem" in a direct democracy context?

When were female captains banned from Starfleet?

Biological Blimps: Propulsion

Should I stop contributing to retirement accounts?

Yosemite Fire Rings - What to Expect?

On a tidally locked planet, would time be quantized?

Open a doc from terminal, but not by its name

Semaphore implementation exception

Porting Java semaphore to MacOSXImplementation of a lock-free fixed-sized allocatorFast non-fair semaphore“Barbershop”-esque Semaphore ImplementationUnfair semaphore in JavaImplementation of stackA very basic semaphore in JavaSimple counting fair semaphore implementationSemaphore of size 1Semaphore skipping additional threads

0

$begingroup$

I am not sure why below code is throwing exception. If I implement the
same code with synchronized at method level then there is no
exception, and it works fine. I think using object lock should also
not have any issue.enter code here

 package practice;

public class CustomSemaphore 

 int count;
 int capacity;
 Object lock = new Object();

 public CustomSemaphore(int capacity) 
 this.count = capacity;
 

 public void acquire() throws InterruptedException 
 synchronized (lock) 
 while (count > capacity) 
 wait();
 
 count++;
 System.out.println(Thread.currentThread().getName() + " got lock and working now");
 

 

 public void release() 
 synchronized (lock) 
 count--;
 notify();
 System.out.println("releasing resource now");
 

 

 public static void main(String[] args) throws InterruptedException 
 final CustomSemaphore sem = new CustomSemaphore(1);
 Runnable acquireTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 try 
 sem.acquire();
 System.out.println(" acquired lock" + Thread.currentThread().getName());
 catch (InterruptedException e) 
 // TODO Auto-generated catch block
 e.printStackTrace();
 
 

 
 ;
 Thread acqThread = new Thread(acquireTask, "acquire");

 Runnable releaseTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 sem.release();
 
 
 ;
 Thread releaseThread = new Thread(releaseTask, "release");
 acqThread.start();
 releaseThread.start();
 acqThread.join();
 releaseThread.join();
 



}

java multithreading concurrency

share|improve this question

asked 10 mins ago

AKSAKS

1161

$endgroup$

add a comment | 

0

$begingroup$

I am not sure why below code is throwing exception. If I implement the
same code with synchronized at method level then there is no
exception, and it works fine. I think using object lock should also
not have any issue.enter code here

 package practice;

public class CustomSemaphore 

 int count;
 int capacity;
 Object lock = new Object();

 public CustomSemaphore(int capacity) 
 this.count = capacity;
 

 public void acquire() throws InterruptedException 
 synchronized (lock) 
 while (count > capacity) 
 wait();
 
 count++;
 System.out.println(Thread.currentThread().getName() + " got lock and working now");
 

 

 public void release() 
 synchronized (lock) 
 count--;
 notify();
 System.out.println("releasing resource now");
 

 

 public static void main(String[] args) throws InterruptedException 
 final CustomSemaphore sem = new CustomSemaphore(1);
 Runnable acquireTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 try 
 sem.acquire();
 System.out.println(" acquired lock" + Thread.currentThread().getName());
 catch (InterruptedException e) 
 // TODO Auto-generated catch block
 e.printStackTrace();
 
 

 
 ;
 Thread acqThread = new Thread(acquireTask, "acquire");

 Runnable releaseTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 sem.release();
 
 
 ;
 Thread releaseThread = new Thread(releaseTask, "release");
 acqThread.start();
 releaseThread.start();
 acqThread.join();
 releaseThread.join();
 



}

java multithreading concurrency

share|improve this question

asked 10 mins ago

AKSAKS

1161

$endgroup$

add a comment | 

$begingroup$

I am not sure why below code is throwing exception. If I implement the
same code with synchronized at method level then there is no
exception, and it works fine. I think using object lock should also
not have any issue.enter code here

 package practice;

public class CustomSemaphore 

 int count;
 int capacity;
 Object lock = new Object();

 public CustomSemaphore(int capacity) 
 this.count = capacity;
 

 public void acquire() throws InterruptedException 
 synchronized (lock) 
 while (count > capacity) 
 wait();
 
 count++;
 System.out.println(Thread.currentThread().getName() + " got lock and working now");
 

 

 public void release() 
 synchronized (lock) 
 count--;
 notify();
 System.out.println("releasing resource now");
 

 

 public static void main(String[] args) throws InterruptedException 
 final CustomSemaphore sem = new CustomSemaphore(1);
 Runnable acquireTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 try 
 sem.acquire();
 System.out.println(" acquired lock" + Thread.currentThread().getName());
 catch (InterruptedException e) 
 // TODO Auto-generated catch block
 e.printStackTrace();
 
 

 
 ;
 Thread acqThread = new Thread(acquireTask, "acquire");

 Runnable releaseTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 sem.release();
 
 
 ;
 Thread releaseThread = new Thread(releaseTask, "release");
 acqThread.start();
 releaseThread.start();
 acqThread.join();
 releaseThread.join();
 



}

java multithreading concurrency

share|improve this question

asked 10 mins ago

AKSAKS

1161

$endgroup$

 package practice;

public class CustomSemaphore 

 int count;
 int capacity;
 Object lock = new Object();

 public CustomSemaphore(int capacity) 
 this.count = capacity;
 

 public void acquire() throws InterruptedException 
 synchronized (lock) 
 while (count > capacity) 
 wait();
 
 count++;
 System.out.println(Thread.currentThread().getName() + " got lock and working now");
 

 

 public void release() 
 synchronized (lock) 
 count--;
 notify();
 System.out.println("releasing resource now");
 

 

 public static void main(String[] args) throws InterruptedException 
 final CustomSemaphore sem = new CustomSemaphore(1);
 Runnable acquireTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 try 
 sem.acquire();
 System.out.println(" acquired lock" + Thread.currentThread().getName());
 catch (InterruptedException e) 
 // TODO Auto-generated catch block
 e.printStackTrace();
 
 

 
 ;
 Thread acqThread = new Thread(acquireTask, "acquire");

 Runnable releaseTask = new Runnable() 

 @Override
 public void run() 
 while (true) 
 sem.release();
 
 
 ;
 Thread releaseThread = new Thread(releaseTask, "release");
 acqThread.start();
 releaseThread.start();
 acqThread.join();
 releaseThread.join();
 



}

share|improve this question

asked 10 mins ago

AKSAKS

1161

share|improve this question

asked 10 mins ago

AKSAKS

1161

asked 10 mins ago

AKSAKS

1161

asked 10 mins ago

AKSAKS

1161