MulticoreWrapper<String,String> wrapper =
new MulticoreWrapper<String,String>(nThreads,
new ThreadsafeProcessor<String,String>() {
@Override
public String process(String input) {
return tagger.tagString(input);
}
@Override
public ThreadsafeProcessor<String, String> newInstance() {
// MaxentTagger is threadsafe
return this;