Multithreading in Java | #53 | StampedLock Class in Java 8 & Higher Versions | A Complete Tutorial смотреть онлайн

JAVA & WEB | Session 20 | Multithreading in Java: https://www.youtube.com/playlist?list=PL6pxHmHF3F5L8PcuSz9w2HCXYvuBtQCk3

Watch the complete web series "Java & Web" on YouTube. It's complete, comprehensive and conceptual.
https://www.youtube.com/c/mynameisGYAN

Follow me on:
Facebook: https://www.facebook.com/mnisGYAN/
Linkedin: https://www.linkedin.com/in/gyan-prakash-tiwary-07215420/
Twitter: https://twitter.com/mnisGYAN
Website: http://mynameisgyan.website/
Be the patron of this channel: https://www.patreon.com/mynameisGYAN

#JavaAndWeb #MultithreadingInJava #OCJP #SCJP #javatutorialforbeginners #javainterviewquestionsandanswersforfreshers #javainterviewquestionsandanswers #javaprogramming

CreateThread.java

import java.util.concurrent.locks.*;
class CreateThread
{
public static void main(String[] args)
{
StampedLock lock = new StampedLock();
MyThread[] t = new MyThread[5];
for(int i=0; i lt 5; i++)
{
t[i] = new MyThread("t"+i, lock);
}
for(int i=0; i lt 5; i++)
{
t[i].start();
}
}
}

MyThread.java for writeLock:

import java.util.concurrent.locks.*;
public class MyThread extends Thread
{
StampedLock lock = null;
public MyThread(String name, StampedLock lock)
{
super(name);
this.lock=lock;
}
public void run()
{
long stamp = lock.writeLock();
System.out.println(Thread.currentThread().getName()+" Got the writeLock ");
try
{
Thread.sleep(5000);
}
catch(InterruptedException e){}
try
{
lock.unlockWrite(stamp);
}
catch(IllegalMonitorStateException e)
{
System.out.println(Thread.currentThread().getName()+" "+e+" did not get the lock");
}
finally
{
System.out.println(Thread.currentThread().getName()+" Finished");
}
}
}

MyThread.java (for tryOptimisticRead())

import java.util.concurrent.locks.*;
public class MyThread extends Thread
{
StampedLock lock = null;
public MyThread(String name, StampedLock lock)
{
super(name);
this.lock=lock;
}
public void run()
{
long stamp = 0;
stamp = lock.tryOptimisticRead();
System.out.println(Thread.currentThread().getName()+" Optimistic Read Stamp is "+stamp);
/*Multiple lines of Codes*/
if(!lock.validate(stamp))
{
stamp = lock.readLock();
System.out.println(Thread.currentThread().getName()+" Changed Stamp is "+stamp);
}
try
{
Thread.sleep(5000);
}
catch(InterruptedException e){}
if(lock.isReadLockStamp(stamp))
{
lock.unlockRead(stamp);
System.out.println(Thread.currentThread().getName()+" Unlocking "+stamp);
}
}
}

MyThread.java for lock conversion:

import java.util.concurrent.locks.*;
public class MyThread extends Thread
{
StampedLock lock = null;
public MyThread(String name, StampedLock lock)
{
super(name);
this.lock=lock;
}
public void run()
{
long stamp = lock.readLock();
System.out.println(Thread.currentThread().getName()+" Got the readLock ");
long stamp1 = lock.tryConvertToWriteLock(stamp);
if(stamp1!=0)
{
stamp=stamp1;
}
try
{
lock.unlockWrite(stamp);
}
catch(IllegalMonitorStateException e)
{
System.out.println(Thread.currentThread().getName()+" "+e+" have not unlocked");
}
finally
{
System.out.println(Thread.currentThread().getName()+" Finished");
}
}
}