private static final Word2Vec word2vectors = getWordVector();
private static Word2Vec getWordVector() {
String PATH;
try {
PATH = new ClassPathResource("models/word2vec_model").getFile().getAbsolutePath();
} catch (Exception e) {
e.printStackTrace();
return null;
}
log.warn("Loading model...");
return WordVectorSerializer.readWord2VecModel(new File(PATH));
}
ExecutorService pools = Executors.newFixedThreadPool(4);
long startTime = System.currentTimeMillis();
List<Future<?>> runnables = new ArrayList<>();
if (word2vectors != null) {
for (int i = 0; i < 3000; i++) {
MyRunnable runnable = new MyRunnable("beautiful", i);
runnables.add(pools.submit(runnable));
}
}
for(Future<?> task: runnables){
try {
task.get();
}catch(InterruptedException ie){
ie.printStackTrace();
}catch(ExecutionException ee){
ee.printStackTrace();
}
}
pools.shutdown();
static class MyRunnable implements Runnable{
private String word;
private int count;
public MyRunnable(String word, int i){
this.word = word;
this.count = i;
}
@Override
public void run() {
Collection<String> words = word2vectors.wordsNearest(word, 5);
log.info("Top 5 cloest words: " + words);
log.info(String.valueOf(count));
}
}
word2vectors.wordsNearest()は、公共図書館のメソッドです。私はプロセスを高速化するために4つのスレッドに同時にメソッドを実行させるつもりです。このスレッドは安全ですか?以下の条件が満たされた場合このコードは安全ですか?
'wordsNearest'メソッドに依存します。 – Oleg
もし私がwordsNearestを制御できないなら、どうすればこのコードを安全にすることができますか? – user697911
他に何も知らないのであれば、 'wordsNearest'を呼び出すときに、一つのスレッドを使うか、' word2vectors'で同期させるだけです。 – Oleg