private void addThreadWriters(Integer threadId) { StringWriter w = new StringWriter(); BufferedWriter bw = new BufferedWriter(w); threadStringWriters.put(threadId, w); threadBufferedWriters.put(threadId, bw); threadResultsReaders.put(threadId, new ResultsReader(bw)); }