{

int CurrentMove;

Infinite()

{

CurrentMove = 1;

}

public static void main (String[] args)

{

System.out.println("Give the number of players: ");

Scanner keyboard = new Scanner(System.in);

Integer N = keyboard.nextInt();

System.out.println("Give the number of loops: ");

Integer Loops = keyboard.nextInt();

Infinite BG = new Infinite ();

ArrayList<Thread> players = new ArrayList<>();

int count=1;

for(int i=0; i<N; i++){

Thread Player = new MyThread(BG, N, Loops, count);

players.add(Player);

count++;

}

players.forEach((p) -> {

p.start();

});

players.forEach((p) -> {

try {

p.join();

} catch (InterruptedException ex) {

Logger.getLogger(Infinite.class.getName()).log(Level.SEVERE, null, ex);

}

});

System.out.println ("Thats All");

}

{

Infinite Board;

Integer N;

Integer player;

Integer turn;

Integer Loops;

public MyThread (Infinite B, int N, int Loops , int player)

{

this.turn = player;

Board = B; this.N=N; this.player=player; this.Loops=Loops;

}

@Override

public void run ()

{

boolean EndIt = false;

while (!EndIt)

{

synchronized (Board)

{

while (Board.CurrentMove != turn)

{

try

{

Board.wait ();

}

catch (InterruptedException ex)

{

}

}

System.out.println ("Do Move : " + Board.CurrentMove + " Player: " + player);

Board.CurrentMove++;

turn=turn+N;

Board.notifyAll ();

}

//System.out.println(turn );

if ((Board.CurrentMove + N) > (Loops+1)) {EndIt = true;}

}

}