Wie ist dieses Wortzahl Schraubengewinde sicher?

Question

Ich bin neu mit Sturm, ich ging durch das Wort zählen Beispiel Sturm. Hier ist die Schraube, die Spur der Grafen hält

public static class WordCount extends BaseBasicBolt { 
    Map<String, Integer> counts = new HashMap<String, Integer>(); 

    @Override 
    public void execute(Tuple tuple, BasicOutputCollector collector) { 
     String word = tuple.getString(0); 
     Integer count = counts.get(word); 
     if (count == null) 
     count = 0; 
     count++; 
     counts.put(word, count); 
     collector.emit(new Values(word, count)); 
    } 

    @Override 
    public void declareOutputFields(OutputFieldsDeclarer declarer) { 
     declarer.declare(new Fields("word", "count")); 
    } 
    } 

Von meinem Verständnis, Sturm mehrere Threads für Bolzen startet die parallel laufen, so wie verwendet HashMap hier Thread-sicher?

Answer 1

[Bolts and spouts] do not need to be thread-safe. Each task has their own instance of the bolt or spout object they're executing, and for any given task Storm calls all spout/bolt methods on a single thread.