java - while 循环条件的同步块(synchronized block)

Question

我正在尝试修复我编写的一段当前存在竞争条件的代码。这样做时，我需要将 while 循环的条件放在 synchronized block 中，但是我不想同步整个 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;
}