Sono riuscito a risolvere specificando il metodo actionPerformed direttamente nella classe dove devo instanziare il Timer.
Ora il problema è che on riesco a sincronizzare...
Il mio scopo è quello di far partire il timer ad ogni passo del seguente ciclo
for (int j=0;j<numSessioni;j++){
Ho messo una wait in quanto il resto del codice deve essere eseguito dopo che il timer ha fatto la notify(), che viene lanciata quando secondi==0.
Purtropo non riesco a realizzare questa cosa perchè mi lancia tante eccezioni.
import java.awt.*;
import javax.swing.*;
import java.awt.event.*;
import javax.swing.JOptionPane;
import javax.swing.Timer;
import java.awt.event.ActionListener;
public class OccupaSedia extends Thread{
private boolean flag;
private int numPersone,numSedie,numSessioni,numThread, secondi;
private int[] arrayPunteggio;
private String[] arrayPersone;
private Sedia[] arraySedie;
Timer time;
Object a = "3";
public OccupaSedia(int numPersone, int numSedie, int numSessioni, int s){
this.numPersone = numPersone;
this.numSedie = numSedie;
this.numSessioni = numSessioni;
this.secondi = s;
//Creazione Timer
this.time = new Timer(1000,new ActionListener()
{
public void actionPerformed(ActionEvent event)
{
synchronized(arraySedie){
if(secondi>0){System.out.println(secondi);}
if(secondi==0){System.out.println("VIA!!!");a.notify();}
secondi--;}
}
});
setFlag(false);
//inizializzazione punteggio
arrayPunteggio=new int[numPersone];
for (int i=0;i<numPersone;i++)
arrayPunteggio[i]=0;
arrayPersone=new String[numPersone];
//inizializzazione persone
for (int i=0;i<numPersone;i++)
arrayPersone[i]="persona"+i;
arraySedie=new Sedia[numSedie];
//inizializzazione sedie
for (int i=0;i<numSedie;i++)
arraySedie[i]=new Sedia(false,"","sedia"+i);
Thread t=null;
for (int j=0;j<numSessioni;j++){
azzeraNumThread();
time.start();
try{a.wait();}
catch(InterruptedException e){}
System.out.println("SESSIONE "+ j);
//avvia threads della sessione
for (int i=0;i<numPersone;i++){
t=new Thread(this);
t.setName(Integer.toString(i));
t.start();
}
setFlag(true);
while(isFlag()==true){}
//libera le sedia a fine sessione
for (int i=0;i<numSedie;i++)
arraySedie[i].setOccupata(false);
}
stampaPunteggio();
System.out.println("GIOCO FINITO");
}
public void run(){
int n=threadContemporanei();
synchronized(arraySedie){
int i=0;
//cerca una sedia libera
if (!arraySedie[arraySedie.length-1].isOccupata())
{while((arraySedie[i].isOccupata()) && (i<arraySedie.length))
i++;
//occupa la sedia trovata libera
if (i<arraySedie.length)
{ arraySedie[i].setOccupata(true);
arraySedie[i].setOccupante(arrayPersone[n]);
arrayPunteggio[n]++;
System.out.println(arraySedie[i].getOccupante()+" ha occupato la sedia "+ arraySedie[i].getNomeSedia());
}
}
else
//se non è stata trovata una sedia libera...
{
System.out.println(arrayPersone[n]+" è rimasto in piedi");
}
}}
//fa partire i threads della sessione "contemporaneamente"
public synchronized int threadContemporanei(){
int n=getNumThread();
setNumThread();
try{
if (numThread!=numPersone){
wait();}
else
{
notifyAll();}
}catch(InterruptedException e){
System.out.println ("Si è verificato un errore: " + e);
System.exit(-1);}
return n;
}
//stampa la classifica
public void stampaPunteggio(){
System.out.println("CLASSIFICA");
for(int i=0;i<arrayPunteggio.length;i++)
System.out.println(arrayPersone[i]+": "+arrayPunteggio[i]);
setFlag(false);
System.out.println();
//System.out.println(isFlag());
}
/**
* @return Returns the numThread.
*/
public synchronized int getNumThread() {
return numThread;
}
/**
* @param numThread The numThread to set.
*/
public synchronized void setNumThread() {
this.numThread++;
}
/**
* @return Returns the numThread.
*/
public synchronized String getNomePersona() {
return arrayPersone[getNumThread()];
}
public synchronized void azzeraNumThread() {
this.numThread=0;
}
/**
* @param flag The flag to set.
*/
public synchronized void setFlag(boolean flag) {
this.flag = flag;
}
/**
* @return Returns the flag.
*/
public synchronized boolean isFlag() {
return flag;
}
}