while循环的条件的同步块

Question

我试图修复一段我写的代码，目前有竞争条件。在这样做时，我需要将while循环的条件放在​​块中，但是我不想同步整个while块，因为这会使资源的其他线程挨饿，而这些线程都是他们需要的。我无法找到一个合理的方式，在没有重复的情况下或者在略微模糊控制流的地方进行。下面的问题是代码的要点：

while ((numRead = in.read(buffer)) != -1) { 
    out.write(buffer); 
} 

，我需要使用in同步。我能想到的（但不认为他们是非常好的）两个可能的解决方案是：

synchronized (this) { 
    numRead = in.read(buffer); 
} 
while (numRead != -1) { 
    out.write(buffer); 
    synchronized (this) { 
     numRead = in.read(buffer); 
    } 
} 

具有不良的重复，这：

while (true) { 
    synchronized (this) { 
     numRead = in.read(buffer); 
    } 
    if (numRead == -1) 
     break; 
    else 
     out.write(buffer); 
} 

这是不是伟大的可读性。有什么建议么？

Answer 1

像下面这样试试。

public testMyMethod() { 
    byte[] buffer = new int[1024]; 
    int numRead = -1; 
    while ((numRead = readInput(buffer)) != -1) { 
     out.write(buffer); 
    } 
} 

//first method 
int readInput(byte[] buffer) { 
    int readLen = -1; 
    synchronized(in) { 
     in.read(buffer); 
    } 
    return readLen; 
} 

//second method, more performant about 3 times, just the synchronization parts 
private static final ReentrantLock inputLock = new ReentrantLock(); 

int readInput(byte[] buffer) { 
    int readLen = -1; 
    inputLock.lock(); 
    try { 
     readLen = in.read(buffer); 
    } finally { 
     inputLock.unlock(); 
    } 
    return readLen; 
}