[JAVA] NON condividere strutture dati tra thread.

[rayman2]

Ciao a tutti,
sto scrivendo un piccolo programma che credo beneficerebbe dell'uso dei thread poiché verrà eseguito su un server con 8 core.
Devo occuparmi dell'analisi di grande insieme di files, ciascuno da trattare nello stesso modo (leggere il file e salvare su un nuovo file le statistiche ricavate). L'idea quindi era di creare una coda condivisa tra più thread (diciamo 8) dalla quale ciascun thread svolgesse il seguente compito: recupera l'elemento in cima della pila (con rimozione), analizza il file indicato, cicla finché la lista non è vuota. Il risultato è il seguente:


package runner;

[import ...];

public class Main {
public static void main(String[] args) throws InterruptedException {
int NTHREADS;
if(args[0] != null) NTHREADS = Integer.parseInt(args[0]);
else NTHREADS = 1;
Long t1 = System.currentTimeMillis();

File dir = new File("directory contenente i file da analizzare");
Queue<String> files = new ConcurrentLinkedQueue<String>();
String[] filesArray = dir.list();
for(int i = 0; i < filesArray.length; i++)
files.offer("directory contenente i file da analizzare" + filesArray[i]);

List<PageAnalyzer> threads = new ArrayList<PageAnalyzer>();
for(int i = 0; i < NTHREADS; i++) {
PageAnalyzer p = new PageAnalyzer(files);
threads.add(p);
p.start();
}

for(PageAnalyzer p: threads)
p.join();

Long t2 = System.currentTimeMillis();
System.out.println("Time required: " + (t2 - t1));
}
}



package runner;
[import ...];

public class PageAnalyzer extends Thread {

private Queue<String> files;
private Map<Integer, Revision> revisions = new ConcurrentHashMap<Integer, Revision>();
private Map<String, User> authors = new ConcurrentHashMap<String, User>();

public PageAnalyzer(Queue<String> files) {
super();
this.files = files;
new Thread(this).start();
}

public void run() {
String file = "(no file)";
try {
while(!files.isEmpty()) {
file = files.poll();
System.out.println(this.getName() + ": " + file);
analyze(file);
}
} catch (Exception e) {
System.out.println("File: " + file + " caused the following exception");
e.printStackTrace(System.out);
}
}

private void initializeGlobalVariables() {
revisions = new ConcurrentHashMap<Integer, Revision>();
authors = new ConcurrentHashMap<String, User>();
}

public void analyze(String file) {
initializeGlobalVariables();
[...algoritmo noioso...]
}

private void processLine(String line) {
[... funzione usata da analyze per manipolare revisions e authors ...]
}

private static void increment(String username) {
[... funzione usata da analyze per manipolare revisions e authors ...]
}
}


revisions e authors sono due strutture dati di supporto che mi sono utili per l'analisi di ciascun file; sono loro che alla fine della funzione analyze() contengono le statistiche che verranno salvate su file. Idealmente, appena inizia l'analisi di un nuovo file, esse andrebbero svuotate ed ecco il perché della funzione initializeGlobalVariables(). Sono dichiarate come globali perché le altre funzioni processLine e increment devono potervi accedere. In realtà durante la reale esecuzione, vengono lanciate molte eccezioni riguardanti il fatto che non vengono trovati alcuni elementi nella mappa. Questo non è un errore della funzione analyze, ho controllato più volte, mi da l'impressione che la struttura dati venga cancellata da un altro thread.
Cosa sto sbagliando? Come faccio ad essere sicuro che revisions e authors vengano usati per l'analisi di un singolo file, senza essere accessibili a qualsiasi altro thread?
Come sempre, grazie