Java Concurrency - อินเตอร์เฟส ReadWriteLock

อินเทอร์เฟซ java.util.concurrent.locks.ReadWriteLock อนุญาตให้อ่านหลายเธรดได้พร้อมกัน แต่มีเธรดเดียวเท่านั้นที่สามารถเขียนได้พร้อมกัน

• Read Lock - หากไม่มีเธรดล็อก ReadWriteLock สำหรับการเขียนเธรดหลายเธรดจะสามารถเข้าถึงล็อกการอ่านได้

• Write Lock - หากไม่มีเธรดกำลังอ่านหรือเขียนเธรดหนึ่งเธรดสามารถเข้าถึงล็อกการเขียนได้

วิธีการล็อค

ต่อไปนี้เป็นรายการวิธีการสำคัญที่มีอยู่ในคลาส Lock

ซีเนียร์	วิธีการและคำอธิบาย
1	public Lock readLock() ส่งคืนล็อคที่ใช้สำหรับการอ่าน
2	public Lock writeLock() ส่งคืนล็อกที่ใช้สำหรับการเขียน

ตัวอย่าง

โปรแกรม TestThread ต่อไปนี้สาธิตวิธีการเหล่านี้ของอินเทอร์เฟซ ReadWriteLock ที่นี่เราใช้ readlock () เพื่อรับ read-lock และ writeLock () เพื่อรับ write-lock

import java.util.concurrent.locks.ReentrantReadWriteLock;

public class TestThread {
   private static final ReentrantReadWriteLock lock = new ReentrantReadWriteLock(true);
   private static String message = "a";

   public static void main(String[] args) throws InterruptedException {
      Thread t1 = new Thread(new WriterA());
      t1.setName("Writer A");
      
      Thread t2 = new Thread(new WriterB());
      t2.setName("Writer B");
      
      Thread t3 = new Thread(new Reader());
      t3.setName("Reader");
      t1.start();
      t2.start();
      t3.start();
      t1.join();
      t2.join();
      t3.join();
   }

   static class Reader implements Runnable {

      public void run() {
         
         if(lock.isWriteLocked()) {
            System.out.println("Write Lock Present.");
         }
         lock.readLock().lock();

         try {
            Long duration = (long) (Math.random() * 10000);
            System.out.println(Thread.currentThread().getName() 
               + "  Time Taken " + (duration / 1000) + " seconds.");
            Thread.sleep(duration);
         } catch (InterruptedException e) {
            e.printStackTrace();
         } finally {
            System.out.println(Thread.currentThread().getName() +": "+ message );
            lock.readLock().unlock();
         }
      }
   }

   static class WriterA implements Runnable {

      public void run() {
         lock.writeLock().lock();
         
         try {
            Long duration = (long) (Math.random() * 10000);
            System.out.println(Thread.currentThread().getName() 
               + "  Time Taken " + (duration / 1000) + " seconds.");
            Thread.sleep(duration);
         } catch (InterruptedException e) {
            e.printStackTrace();
         } finally {
            message = message.concat("a");
            lock.writeLock().unlock();
         }
      }
   }

   static class WriterB implements Runnable {

      public void run() {
         lock.writeLock().lock();
         
         try {
            Long duration = (long) (Math.random() * 10000);
            System.out.println(Thread.currentThread().getName() 
               + "  Time Taken " + (duration / 1000) + " seconds.");
            Thread.sleep(duration);
         } catch (InterruptedException e) {
            e.printStackTrace();
         } finally {
            message = message.concat("b");
            lock.writeLock().unlock();
         }
      }
   }
}

สิ่งนี้จะให้ผลลัพธ์ดังต่อไปนี้

เอาต์พุต

Writer A  Time Taken 6 seconds.
Write Lock Present.
Writer B  Time Taken 2 seconds.
Reader  Time Taken 0 seconds.
Reader: aab