Java男女皆宜的卫生间

有各种各样的线索：男人和女人.两者都想使用数量为BATHROOM_SIZE的相同资源. 5条规则：

>在发出信号需要使用资源之后,每个线程都应该等到他能够使用它.
>当多个BATHOOM_SIZE线程同时使用资源时,防止出现这种情况.
>防止女人和男人同时使用浴室.
>线程应同时使用资源.如果有一种类型的线程很多,那么BATHROOM_SIZE线程应该使用资源.
>防止饥饿.

结果

效劳于：

1女,1人,5女,5人

失败：

5women1men,5men1women,2men2women,5men5women.

自从周一以来我一直在尝试让它成功,现在我的想法已经用完了.

码

所以我的任务是编写实现BathroomInterface的Bathroom.java类：

public interface BathroomInterface {

    public static final int BATHROOM_SIZE = 3; //3 is just example
    void manEnter();
    void manExit();
    void womanEnter();
    void womanExit();
}

在系统中有许多男人和女人的线程像这样工作：

for(int i = 0; i < n; i++) {
  bathroom.manEnter();
  //uses bathroom random amount of time
  bathroom.manExit();
}

for(int i = 0; i < m; i++) {
  bathroom.womanEnter();
  //uses bathroom random amount of time
  bathroom.womanExit();
}

我也有Bathroom.java类的方案,我必须扩展：

import java.util.concurrent.Semaphore;

public class Bathroom implements BathroomInterface {


    private Semaphore mutex = new Semaphore(1,true);

    public void womanEnter() {
        mutex.acquireUninterruptibly();
    }

    public void womanExit() {
        mutex.release();
    }

    public void manEnter() {
        mutex.acquireUninterruptibly();        
    }

    public void manExit() {
        mutex.release();
    }
}

这是我到目前为止所做的：

import java.util.concurrent.Semaphore;

public class Bathroom implements BathroomInterface {
    int manW=0,manU=0,womanW=0,womanU=0; //*U-using,*W-waiting
    private Semaphore mutex = new Semaphore(1,false);

    public void womanEnter() {
        womanW++;
        StateChange();
    }

    public void womanExit() {
        womanU--;
        mutex.release();
        StateChange();
    }

    public void manEnter(){
        manW++;
        StateChange();
    }

    public void manExit() {
        manU--;
        mutex.release();
        StateChange();
    }

    void StateChange() {
        if(womanU==0 && manU==0) {
            if(manW>womanW) {
                while(manW>0 && manU<BATHROOM_SIZE) {
                    manW--;
                    manU++;
                    mutex.acquireUninterruptibly();
                }
            }
            else {
                while(womanW>0 && womanU<BATHROOM_SIZE) {
                    womanW--;
                    womanU++;
                    mutex.acquireUninterruptibly();
                }
            }
        }
        if(womanU==0 && manU<BATHROOM_SIZE) {
            while(manW>0 && manU<BATHROOM_SIZE) {
                manW--;
                manU++;
                mutex.acquireUninterruptibly();
            }
        }
        if(manU==0 && womanU<BATHROOM_SIZE) {
            while(womanW>0 && womanU<BATHROOM_SIZE) {
                womanW--;
                womanU++;
                mutex.acquireUninterruptibly();
            }
        }
    }
}