Не могу понять, почему в данном примере не получается работать с 2 потоками
public class Start {
public static void main(String[] args) {
Start start = new Start();
start.init();
}
private void init() {
Game game = new Game();
MyThread myThread1 = new MyThread(game, "Ping");
MyThread myThread2 = new MyThread(game, "Pong");
myThread1.start();
myThread2.start();
}
private class MyThread extends Thread {
Game game;
public MyThread(Game game, String name) {
setName(name);
this.game = game;
}
@Override
public void run() {
while (game.isGameNotOver()) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
game.kick(getName());
}
}
}
private class Game {
int counter = 0;
public synchronized void kick(String name) {
System.out.println(name + " " + counter);
counter++;
}
public boolean isGameNotOver() {
return counter < 10;
}
}
}
А именно, если Sleep стоит <=100, то возможны ситуации что 1 поток сделает всю работы. Если поставить 500, то проблема перестанет наблюдаться.
Пытался сделать по аналогии с этой задачей Но только убрал синглтон и проверку по имени потока. Явно ведь, проверка имени это какая-то.... не обычность.
kick
, что означает, что одновременно внутри метода может быть только один поток. Всё, больше никаких гарантий у вас нет. Потому нет ничего удивительного, что есть вероятность .что один поток сделает всю работу. Мало того, при маленьком значенни в thread.sleep(...), первый поток может сделать всю работу просто потому, что второй поток не успел ещё стартануть к тому моменту - запуск потока таки дорогая операция.synchronized
метод, а когда вышел, тут уже второй заходит сразу.