鎖定訪問另一個類，從運行方法

Question

相當複雜的代碼，但這是一個非常簡單的問題。

我有一個線程，這是它的run方法：

public void run() //gets pages and writes to them 
{ // i printed the pageId of every process to check they are running at the same time and competing for resources 
    for(ProcessCycle currentCycle : processCycles.getProcessCycles()) 
    { 
     Long[] longArray = new Long[currentCycle.getPages().size()]; 
     try { 
      Page<byte[]>[] newPages = mmu.getPages(currentCycle.getPages().toArray(longArray)); 
      for(int i = 0; i < newPages.length; i++) 
      { 
       MMULogger.getInstance().write("GP:P" + id + " " + currentCycle.getPages().get(i) + " " + Arrays.toString(currentCycle.getData().get(i)), Level.INFO); 
      } 
      List<byte[]> currentPageData = currentCycle.getData(); 
      System.out.println("process id " + id); 
      for(int i = 0; i < newPages.length;i++) 
      { 
       byte[] currentData = currentPageData.get(i); 
       newPages[i].setContent(currentData); 
      } 
      Thread.sleep(currentCycle.getSleepMs()); 
     } catch (ClassNotFoundException | IOException | InterruptedException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 
} 

不打擾閱讀它的全部。只需注意在mmu.getpages之後有一個for循環。

雖然進程在for循環中，但我想鎖定對所有其他線程的訪問權限。 synchronized是不好的，因爲我的原始過程不再是mmu，而是在for循環中，並且reentrantlock可能是個好主意，但我對語法不熟悉並遇到了一些問題。

長話短說 - 我如何讓所有其他線程等待，而某些線程在mmu.getpages之後的for循環內？

Answer 1

通常我選擇了這樣的做法：如果

private Object lock = new Object(); 
public void run() //gets pages and writes to them 
{ // i printed the pageId of every process to check they are running at the same time and competing for resources 
    for(ProcessCycle currentCycle : processCycles.getProcessCycles()) 
    { 
     Long[] longArray = new Long[currentCycle.getPages().size()]; 
     try { 
      synchrnonized(lock) { 
       Page<byte[]>[] newPages = mmu.getPages(currentCycle.getPages().toArray(longArray)); 
       for(int i = 0; i < newPages.length; i++) 
       { 
        MMULogger.getInstance().write("GP:P" + id + " " + currentCycle.getPages().get(i) + " " + Arrays.toString(currentCycle.getData().get(i)), Level.INFO); 
       } 
      } 
      List<byte[]> currentPageData = currentCycle.getData(); 
      System.out.println("process id " + id); 
      for(int i = 0; i < newPages.length;i++) 
      { 
       byte[] currentData = currentPageData.get(i); 
       newPages[i].setContent(currentData); 
      } 
      Thread.sleep(currentCycle.getSleepMs()); 
     } catch (ClassNotFoundException | IOException | InterruptedException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 
} 

不知道有更好的辦法。這隻會在所有線程共享此對象的相同實例時按預期工作，否則必須使lock成爲靜態成員變量。

Answer 2

在我看來，ReadWriteLock可能是一個最好的方法。

事情是這樣的：

public class MmuClass { 

    private ReadWriteLock blockGetPages = new ReentrantReadWriteLock(); 

    public byte [] getPages(...) { 
     try{ 
      blockGetPages.readLock().lock(); 
      // ... 
      // ... 
      // ... 
      return result; 
     finally{ 
      blockGetPages.readLock().unlock(); 
     } 
    } 

    public void lockAccessToGetPages(){ 
     blockGetPages.writeLock().lock(); 
    } 

    public void unlockAccessToGetPages(){ 
     blockGetPages.writeLock().unlock(); 
    } 
} 

和

Page<byte[]>[] newPages = mmu.getPages(currentCycle.getPages().toArray(longArray)); 
try{ 
    mmu.lockAccessToGetPages(); 
    for(int i = 0; i < newPages.length; i++) { 
     MMULogger.getInstance().write("GP:P" + id + " " + currentCycle.getPages().get(i) + " " + Arrays.toString(currentCycle.getData().get(i)), Level.INFO); 
    } 
} finally{ 
    mmu.unlockAccessToGetPages(); 
} 

在這種解決方案的所有 「讀者」 可以同時調用getPages()，訪問被呼叫阻止unlockAccessToGetPages()後調用lockAccessToGetPages()和暢通之後。如果一個線程以寫入模式鎖定對象，則只有該線程才能訪問該方法。如果某個線程試圖將其鎖定在寫入模式下，則必須等到所有當前位於metod內部的讀取器完成其​​分支並離開該方法。