0

我在同步我的idMap. 此地图正用于两种run()同时运行的方法。在第一个 run() 方法中，我只是将事件 id 值）映射到响应 id（键）。在第二个 run() 方法中，我希望获得具有相同响应 id（键）的事件 id（值）。但是，有时会有一些事件 ID，有时无法获得它们。该程序编译得很好，但我不是线程专家，我相信线程导致它idMap不同步。我的问题很简单，我怎样才能使idMap工作顺利进行并按照我的意图获取事件 ID？ 

ConcurrentHashMap<String, String> idMap = new ConcurrentHashMap<String, String>();
ConcurrentHashMap<String, ExecutorService> executors = new ConcurrentHashMap<String, ExecutorService>();

private final class ResponderTask implements Runnable {
    private ResponderTask(Event event) {
        this.event = event;
    }
    // 1st run()    
    public void run() {
        idMap.put(response.getId(), event.getId()); 
    }
}//end ResponderTask 

private final class QuoteTask implements Runnable {
    //constructor
    //2nd run() 
    public void run() {
        IdMap.get(response.getId());
    }
}//end QuoteTask

public void onResponse(final Response response) {

    ExecutorService quoteExecutor = executors.get(response.getId());
    if (quoteExecutor == null) {
        quoteExecutor = Executors.newSingleThreadExecutor();                
        executors.put(event.getId(), quoteExecutor);            
    }
    quoteExecutor.execute(new ResponderTask(event));
}
4

1 回答 1

0

但是，有时会有一些事件 ID，有时无法获得它们。该程序编译得很好，但我不是线程专家，我相信线程导致这个 idMap 不同步。

idMap是一个ConcurrentHashMap被许多人正确同步和高度使用和测试的。如果查找时 id 不在地图中，则它没有被放在那里。如果您对您的代码进行更多解释，我们可能会找到您的问题。

例如，我看不到response对象的来源。是否有可能ResponseTask正在处理与您期望的不同的响应？response和event应该是同一个论点吗？

我的问题很简单，我怎样才能使 idMap 顺利工作并按我的意图获取事件 ID？

很难弄清楚程序的正确操作应该是什么。如果您正在寻找其他线程来获取事件，您可以使用BlockingQueue. 然后你的另一个线程可以做一个queue.take()等待，直到有一个事件要处理。但我不确定这里的目标是什么。

一件非常奇怪的事情是使用ExecutorService. 你真的需要多个吗？我怀疑您真的应该使用单个Executors.newCachedThreadPool(). 但是，也许您希望单个线程处理具有相同 id 的所有请求，在这种情况下您的代码应该可以工作。我假设您想关闭应用程序时正在执行以下操作：

for (ExecutorService executor : executors.values()) {
    executor.shutdown();
}
于 2013-10-21T21:55:19.677 回答