1 Поток:
public class First implements Runnable {
private Semaphore semaphore;
public First(Semaphore semaphore) {
this.semaphore = semaphore;
}
@Override
public void run(){
for (int i = 0; i < 5; i++) {
semaphore.enter();
System.out.println(1);
semaphore.leave();
}
}
}
2 поток:
public class Second implements Runnable {
private Semaphore semaphore;
public SequentalCleaner(Semaphore semaphore) {
this.semaphore = semaphore;
}
@Override
public void run(){
for (int i = 0; i < 5; i++) {
semaphore.enter();
System.out.println(2);
semaphore.leave();
}
}
}
Семафор:
public class Semaphore {
private int cur;
public Semaphore(int cur) {
this.cur = cur;
}
public void enter() {
while(cur == 0){
}
--cur;
}
public void leave(){
++cur;
}
}
Это не синхронизировано. Как сделать синхронизированным? Вывод при запуске потоков:
2 1 2 1 2 1 1 1
или, например
1 1 1 1 1 2 2 2 2 2
Т.е. они даже не заканчивают свою работу.
leave
условиеwhile (cur != 0){}
? o_O