2013-スレッド同期の使用
3834 ワード
実際のプロジェクト開発では、効率を向上させるためにプログラムの同時進行を制御するためにスレッドクラスを使用する必要がある場合が多いが、スレッドセキュリティの問題にも関連しています.
簡単なスレッド制御Executorsクラスを使用して簡単に実装できます.具体的には、
記事1:Java ScheduledThreadPoolExecutorタスクの遅延または周期的な実行
記事2:ExecutorsとThreadPoolExecutor 2を使用してキューを使用
記事3:ForkJoin-タスク分割マージプロセッサJDK 7の新機能は、大きなタスクを分割して処理し、結果をマージすることができます.
しかし、いくつかのビジネスに関連するスレッド制御は依然として伝統的な方法で実現する必要があります.以下のコードの背景:大量の要求アクセスがあり、要求パラメータが多く重複し、キャッシュメカニズムに参加し、スレッドの安全を保証します.
サービスクラスとWorkerクラスで実装します.具体的なコードは次のとおりです.
簡単なスレッド制御Executorsクラスを使用して簡単に実装できます.具体的には、
記事1:Java ScheduledThreadPoolExecutorタスクの遅延または周期的な実行
記事2:ExecutorsとThreadPoolExecutor 2を使用してキューを使用
記事3:ForkJoin-タスク分割マージプロセッサJDK 7の新機能は、大きなタスクを分割して処理し、結果をマージすることができます.
しかし、いくつかのビジネスに関連するスレッド制御は依然として伝統的な方法で実現する必要があります.以下のコードの背景:大量の要求アクセスがあり、要求パラメータが多く重複し、キャッシュメカニズムに参加し、スレッドの安全を保証します.
サービスクラスとWorkerクラスで実装します.具体的なコードは次のとおりです.
package itour.cn.fare.gateway.service;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class ObeQueryServiceImpl implements ObeQueryService {
private static Logger log = LoggerFactory.getLogger(ObeQueryServiceImpl.class);
private static ObeQueryServiceImpl service = new ObeQueryServiceImpl();
private Map<String, Integer> avhTask = new HashMap<String, Integer>();// ，
private Map<String, Object> avhLock = new HashMap<String, Object>();// ，
private void getAvh(String key, String org, String dis, String date, String airCompany) {
synchronized (this) {
if (avhLock.get(key) == null) {// ，
avhLock.put(key, new byte[0]);
log.debug(String.format("AV create lock:%s ", key));
}
}
synchronized (avhLock.get(key)) {
// ，
if (avhTask.get(key) == null) {
avhTask.put(key, new Integer(1));
ObeAvhWorker worker = new ObeAvhWorker(key, org, dis, date, airCompany);
log.debug(String.format("AV[%s] AvWorker Start ", key));
worker.start();
}
try {
log.debug(String.format("AV[%s] Waitting AvWorker ", key));
avhLock.get(key).wait();// run
} catch (InterruptedException e) {
log.error(e.getMessage(), e);
}
log.debug(String.format("AV[%s] AvWorker Notified", key));
}
}
public Map<String, Integer> getAvhTask() {
return avhTask;
}
public Map<String, Object> getAvhLock() {
return avhLock;
}
}