我想知道我們什麼時候需要使用threadlocal變量?我有一個運行多個線程的代碼,每個代碼都讀取S3上的一些文件,我希望跟蹤這些文件完全讀出多少行,這裏是我的代碼:是否需要在這裏使用ThreadLocal?
final AtomicInteger logLineCounter = new AtomicInteger(0);
for(File f : files) {
calls.add(_exec.submit(new Callable<Void>() {
@Override
public Void call() throws Exception {
readNWrite(f, logLineCounter);
return null;
}
}));
}
for (Future<Void> f : calls) {
try {
f.get();
} catch (Exception e) {
//
}
}
LOGGER.info("Total number of lines: " + logLineCounter);
...
private void readNWrite(File f, AtomicInteger counter) {
Iterator<Activity> it = _dataReader.read(file);
int lineCnt = 0;
if (it != null && it.hasNext()) {
while(it.hasNext()) {
lineCnt++;
// write to temp file here
}
counter.getAndAdd(lineCnt);
}
}
我的問題是,我需要做的lineCnt
在readNWrite()
方法是ThreadLocal的?