Java Concurrency - ล็อคอินเทอร์เฟซ

อินเตอร์เฟส java.util.concurrent.locks.Lock ถูกใช้เพื่อเป็นกลไกการซิงโครไนซ์เธรดที่คล้ายกับบล็อกที่ซิงโครไนซ์ กลไกการล็อคแบบใหม่มีความยืดหยุ่นมากกว่าและมีตัวเลือกมากกว่าบล็อกที่ซิงโครไนซ์ ความแตกต่างหลักระหว่างล็อคและบล็อกซิงโครไนซ์มีดังต่อไปนี้ -

• Guarantee of sequence- บล็อกที่ซิงโครไนซ์ไม่ได้รับประกันลำดับใด ๆ ที่เธรดรอจะได้รับการเข้าถึง ล็อคอินเทอร์เฟซจัดการมัน

• No timeout- บล็อกที่ซิงโครไนซ์ไม่มีตัวเลือกในการหมดเวลาหากไม่ได้รับการล็อก ล็อคอินเทอร์เฟซมีตัวเลือกดังกล่าว

• Single method - บล็อกที่ซิงโครไนซ์จะต้องมีอยู่อย่างครบถ้วนภายในวิธีการเดียวในขณะที่สามารถเรียกวิธีการล็อก () และปลดล็อก () ของอินเทอร์เฟซการล็อกด้วยวิธีการต่างๆ

วิธีการล็อค

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

ซีเนียร์	วิธีการและคำอธิบาย
1	public void lock() ได้รับการล็อค
2	public void lockInterruptibly() ได้รับการล็อกเว้นแต่เธรดปัจจุบันจะถูกขัดจังหวะ
3	public Condition newCondition() ส่งคืนอินสแตนซ์ Condition ใหม่ที่เชื่อมโยงกับอินสแตนซ์ Lock นี้
4	public boolean tryLock() จะได้รับการล็อคก็ต่อเมื่อมันว่างในเวลาที่เรียกใช้
5	public boolean tryLock() จะได้รับการล็อคก็ต่อเมื่อมันว่างในเวลาที่เรียกใช้
6	public boolean tryLock(long time, TimeUnit unit) ได้รับการล็อกหากว่างภายในเวลารอที่กำหนดและเธรดปัจจุบันไม่ถูกขัดจังหวะ
7	public void unlock() ปลดล็อค

ตัวอย่าง

โปรแกรม TestThread ต่อไปนี้แสดงวิธีการเหล่านี้บางส่วนของอินเทอร์เฟซ Lock ที่นี่เราได้ใช้ lock () เพื่อรับล็อคและปลดล็อก () เพื่อคลายล็อก

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

class PrintDemo {
   private final Lock queueLock = new ReentrantLock();

   public void print() {
      queueLock.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.printf(
            "%s printed the document successfully.\n", Thread.currentThread().getName());
         queueLock.unlock();
      }
   }
}

class ThreadDemo extends Thread {
   PrintDemo  printDemo;

   ThreadDemo(String name,  PrintDemo printDemo) {
      super(name);
      this.printDemo = printDemo;
   }   

   @Override
   public void run() {
      System.out.printf(
         "%s starts printing a document\n", Thread.currentThread().getName());
      printDemo.print();
   }
}

public class TestThread {

   public static void main(String args[]) {
      PrintDemo PD = new PrintDemo();

      ThreadDemo t1 = new ThreadDemo("Thread - 1 ", PD);
      ThreadDemo t2 = new ThreadDemo("Thread - 2 ", PD);
      ThreadDemo t3 = new ThreadDemo("Thread - 3 ", PD);
      ThreadDemo t4 = new ThreadDemo("Thread - 4 ", PD);

      t1.start();
      t2.start();
      t3.start();
      t4.start();
   }
}

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

เอาต์พุต

Thread - 1  starts printing a document
Thread - 4  starts printing a document
Thread - 3  starts printing a document
Thread - 2  starts printing a document
Thread - 1   Time Taken 4 seconds.
Thread - 1  printed the document successfully.
Thread - 4   Time Taken 3 seconds.
Thread - 4  printed the document successfully.
Thread - 3   Time Taken 5 seconds.
Thread - 3  printed the document successfully.
Thread - 2   Time Taken 4 seconds.
Thread - 2  printed the document successfully.

เราใช้คลาส ReentrantLock เป็นการใช้อินเทอร์เฟซ Lock ที่นี่ คลาส ReentrantLock อนุญาตให้เธรดล็อกเมธอดแม้ว่าจะมีการล็อกเมธอดอื่นอยู่แล้วก็ตาม