gpt4 book ai didi

java - 调用两个同步方法时死锁

转载 作者:行者123 更新时间:2023-11-29 07:46:47 26 4
gpt4 key购买 nike

class Downloader extends Thread {
private InputStream in;
private OutputStream out;
private ArrayList<ProgressListener> listeners;
public Downloader(URL url, String outputFilename) throws IOException {
in = url.openConnection().getInputStream();
out = new FileOutputStream(outputFilename);
listeners = new ArrayList<ProgressListener>();
}
public synchronized void addListener(ProgressListener listener) {
listeners.add(listener);
}
public synchronized void removeListener(ProgressListener listener) {
listeners.remove(listener);
}

private synchronized void updateProgress(int n) {
for (ProgressListener listener: listeners)
listener.onProgress(n);
}
public void run() {
int n = 0, total = 0;
byte[] buffer = new byte[1024];
try {
while((n = in.read(buffer)) != -1) {
out.write(buffer, 0, n);
total += n;
updateProgress(total);
}
out.flush();
} catch (IOException e) { }
}
}

以上代码来自《七周七个并发模型》一书。书中说上面的代码有死锁的可能性,因为同步方法 updateProgress 调用了可能获取另一个锁的外来方法 [onProgress]。由于我们没有正确的顺序获得两个锁,因此可能会发生死锁。

谁能解释一下上述场景中的死锁是如何发生的?

提前致谢。

最佳答案

最好将使用 synchronized 的对象设为私有(private)。

由于您在 Downloader 上同步,您不知道其他线程是否也在 Downloader 上同步。

以下监听器导致死锁:

MyProgressListener extends ProgressListener {

public Downloader downloader;
public void onProgress(int n) {
Thread t = new Thread() {
@Override
public void run() {
synchronized(downloader) {
// do something ...
}
}
};
t.start();
t.join();
}
}

死锁代码:

Downloader d = new Downloader(...);
MyProgressListener l = new MyProgressListener();
l.downloader = d;
d.addListener(l);
d.run();

如果您运行该代码,将发生以下情况:

  1. 主线程到达 updateProgress 并在 Downloader 上获取锁
  2. 调用MyProgressListeneronProgress方法,启动新线程t
  3. 主线程到达t.join();

在这种情况下,主线程在 t 完成之前无法继续,但是要使 t 完成,主线程必须释放它对 的锁定下载程序,但这不会发生,因为主线程无法继续 -> 死锁

关于java - 调用两个同步方法时死锁,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/25050574/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com