提问者:小点点

没有线程死锁实现无法工作。睡眠


我试图理解死锁,并相应地尝试创建死锁的实现。 这个想法是创建一个循环锁定的模拟。 下面是我的可运行实现:

public class WorkDelegator implements Runnable {

private static final Logger LOGGER = Logger.getGlobal();

WorkDelegator workDelegatorSupplier;
private final String name;

public WorkDelegator(String name) {
    this.name = name;
}

public void setWorkDelegatorSupplier(WorkDelegator workDelegatorSupplier) {
    this.workDelegatorSupplier = workDelegatorSupplier;
}

public void delegate(){

    synchronized (workDelegatorSupplier) {
//            try {
//                Thread.sleep(300);
//            } catch (InterruptedException e) {
//                LOGGER.warning("InterruptedException in Task " + name);
//            }
        workDelegatorSupplier.delegate();
    }
    LOGGER.info("task delegated from " + name + "to " + workDelegatorSupplier);
}

@Override
public void run() {
    LOGGER.info(this + " is trying to delegate task to " + workDelegatorSupplier);
    delegate();
}
}

一组WorkDelegator实例通过调用delegationvoid循环地相互委托工作。 问题是,如果注释掉的代码也在执行,那么它可以正常工作,但是为什么我会得到StackOverflowError而没有线程睡眠呢?

PS-代理工厂类:

public class WorkDelegatorFactory {

public List<WorkDelegator> getDelegatorsList(int size) {

    List<WorkDelegator> workDelegatorList = new ArrayList<>();
    for (int i = 0; i < size ; i++) {
        workDelegatorList.add(new WorkDelegator(String.valueOf(i)));
    }
    WorkDelegator firstDelegator = workDelegatorList.get(0);
    WorkDelegator lastDelegator = workDelegatorList.get(size-1);
    lastDelegator.setWorkDelegatorSupplier(firstDelegator);
    for (int i = 0; i < size-1; i++) {
        workDelegatorList.get(i).setWorkDelegatorSupplier(workDelegatorList.get(i+1));
    }
    return workDelegatorList;
}
}

共1个答案

匿名用户

如果没有sleep,启动的第一个线程可以在其他线程启动之前执行大量递归调用。 这允许它们获取足够的同步锁,以无限期地继续,并最终耗尽堆栈深度。 其他启动的线程到达得太晚,无法获取它们的第一个同步锁,只能闲置着。

使用sleep,每个线程只能获取一个同步锁,任何线程都不能超前到可以循环的程度。

您看到的是并发编程的一个困难部分:您知道每个线程中的顺序,但不知道每个线程与其他线程的关系。

相关问题