Cách khóa một phương thức java để bảo vệ nhiều lời gọi

Question

Tôi có một ứng dụng cứ 15 phút một lần để sao chép từ cơ sở dữ liệu từ xa. Nó chỉ giữ hai kho lưu trữ đồng bộ. Một khi sao chép này là đi nó không thể làm điều đó một lần nữa. Tôi đã thiết lập cấu trúc sau nhưng tôi không chắc đó có phải là cách tiếp cận chính xác hay không.

public class ReplicatorRunner { 

     private static Lock lock = new ReentrantLock(); 

     public replicate() { 

      if (lock.tryLock()) { 
       try { 
        // long running process 
       } catch (Exception e) {     
       } finally { 
        lock.unlock(); 
       }    
      } else { 
       throw new IllegalStateException("already replicating"); 
      } 

     } 

} 

public class ReplicatorRunnerInvocator { 

    public void someMethod() { 

     try { 
      ReplicatorRunner replicator = new ReplicatorRunner(); 
      replicator.replicate(); 
     } catch (IllegalStateException e) { 
      e.printStackTrace(); 
     } 

    } 

} 

Các ReplicatorRunner là lớp sở hữu phương pháp replicate mà chỉ có thể chạy cùng một lúc.

Chỉnh sửa. Tôi cần cuộc gọi tiếp theo thất bại (không chặn) nếu phương thức đã chạy trên bất kỳ phiên bản nào.

Answer 1

Điều này có vẻ tốt. ReentrantLock.tryLock() sẽ chỉ cung cấp khóa cho một sợi, do đó, không cần thiết phải synchronized. Nó cũng ngăn chặn việc chặn vốn có trong đồng bộ hóa mà bạn nói là một yêu cầu. ReentrantLock là Serializable, vì vậy nên làm việc trên cụm của bạn.

.

Answer 2

hãy xem lớp Semaphore here hoặc đánh dấu phương thức là được đồng bộ luồng thực thi phương thức tại bất kỳ thời điểm đã định nào sở hữu một khóa trên đó tránh các chủ đề khác gọi phương thức cho đến khi kết thúc.
Chỉnh sửa: nếu bạn muốn các chủ đề khác không thành công, bạn có thể sử dụng Lock và kiểm tra xem khóa có được sử dụng theo phương pháp tryLock hay không.

Answer 3

Thay đổi public replicate()-public synchronized replicate()

Bằng cách đó lặp lại sẽ chỉ bao giờ cho phép truy cập vào một thread tại một thời điểm. Bạn cũng sẽ có thể xóa ReentrantLock và tất cả các mã liên quan.

Answer 4

Nếu không nhìn vào các chi tiết cụ thể của ReentrantLock, nó xảy ra với tôi rằng việc ngăn ngừa nhiều thói quen sao chép đồng thời này sẽ bị giới hạn trong một cá thể JVM duy nhất.

Nếu một phiên bản khác của lớp được khởi động trong một JVM riêng biệt, thì bạn có thể gặp sự cố.

Tại sao không đặt cơ chế khóa trên cơ sở dữ liệu? tức là Một hàng trong bảng điều khiển được đặt thành giá trị mô tả liệu bản sao có đang chạy bận hay không và đặt lại giá trị khi sao chép xong.

Answer 5

tôi đã kết thúc bằng cách sử dụng sau đây:

public class ReplicatorRunner { 

     private static Semaphore lock = new Semaphore(1); 

     public replicate() { 

      if (lock.tryAcquire()) { 
       try {        
        // basic setup     
        Thread t = new Thread(new Runnable() { 
         public void run() { 
          try { 
           // long running process        
          } catch Exception (e) { 
           // handle the exceptions 
          } finally { 
           lock.release(); 
          } 
         } 
        }) 
        t.start(); 

       } catch (Exception e) { 
        // in case something goes wrong 
        // before the thread starts 
        lock.release(); 
       }    
      } else { 
       throw new IllegalStateException("already replicating"); 
      } 

     } 

} 

public class ReplicatorRunnerInvocator { 

    public void someMethod() { 

     try { 
      ReplicatorRunner replicator = new ReplicatorRunner(); 
      replicator.replicate(); 
     } catch (IllegalStateException e) { 
      e.printStackTrace(); 
     } 

    } 

}