Java：キューからオブジェクトを同時に削除する。

Question

Iオブジェクトfooが有する2つのキュー（b_queueとc_queue）、タイプBのオブジェクトで満たされた一方及び他方を含むオブジェクトの階層があり、いくつかのオブジェクトBおよびC

のインスタンスの数百を作成するアプリケーションを持っています

BまたはCで何らかのイベントが発生した場合、オブジェクトFooのキューから自分自身を削除する必要があります。

私の解決策は、オブジェクトBまたはCの構築時に、Fooのインスタンス（foo_instと呼ぶ）を渡してキューに格納します。 次にBまたはCの中でfoo_inst.b_queue.remove（this）を呼び出すことができます。

1）これは効果的な方法ですか、これを避けるべきですか？

BとCの両方がRunnableオブジェクトであり、ThreadPoolExecutorでキューに入れられます。これは、それらがワークキュー上に2回ある可能性があり、foo_inst.b_queue.remove（this）を同時に呼び出すか、すでに完了した後に呼び出すことを意味する可能性があります。

2）これにも問題がありますか？

ご迷惑をおかけして申し訳ありません。

わかりましたこれまでのところ、私はいくつかの助けを借りてはるかにこれを取得することができた（これ以上のヘルプ歓迎）：。

public class Foo implements Foo_interface{ 

ConcurrentHashMap<Key,B> b_map = new ConcurrentHashMap<Key,B>(); 
ConcurrentHashMap<Key,C> c_map = new ConcurrentHashMap<Key,C>(); 

public void removeB(Key k){ 
    b_map.remove(k); 
} 
public void removeC(Key k){ 
    c_map.remove(k); 
} 


private class B implements Runnable{ 

    Foo foo_inst; 
    Key key; 

    public B(Foo foo,Key key){ 
     this.foo=foo; 
     this.key=key; 
    } 
    public void run(){ 
     try{ 
      //some code 
     }catch(Exception e{ 
      foo.removeB(key); 
     } 
    } 
} 

private class C implements Runnable{ 

    Foo foo_inst; 
    Key key; 

    public C(Foo foo,Key key){ 
     this.foo=foo; 
     this.key = key; 
    } 
    public void run(){ 
     try{ 
      //some code 
     }catch(Exception e{ 
      foo.removeC(key); 
     } 
    } 
} 

}

Answer 1

- このように、あなたは2つの別々のhashsetsにBとCのインスタンスを格納することができます。実際には、HashSet<Object> bnc = HashSet<Object>()と宣言することで、BオブジェクトとCオブジェクトの両方に1つのハッシュセットを使用することもできます。特定のインスタンスを削除する場合は、remove（Object o）メソッドを使用します。これを同時に実行したい場合は、最も簡単なのは、それぞれのハッシュセットまたはハッシュセットへのアクセスを同期させることです。

EDIT：

ええと、私はちょうどあなたのソリューションを見て、ここにあなたがHashSetsでスレッドセーフな方法でこれを行うことができます方法です。

public class Foo implements Foo_interface{  
    HashSet<Object> bnc = new HashSet<Object>(); 
    //thread safety using monitors 
    public synchronized insert(Object o) { 
     bnc.add(o); 
    } 
    public synchronized delete(Object o) { 
     bnc.remove(o); 
    } 
} 

private class B implements Runnable{ 

    Foo f; 

    public B(Foo f) { 
     this.f = f; 
     this.f.insert(this); 
    } 

    public void run(){ 
     try{ 
      //some code 
     }catch(Exception e{ 
      this.f.delete(this); 
     } 
    } 
} 

private class C implements Runnable{ 

    Foo f; 

    public C(Foo f) { 
     this.f = f; 
     this.f.insert(this); 
    } 

    public void run(){ 
     try{ 
      //some code 
     }catch(Exception e{ 
      this.f.delete(this); 
     } 
    } 
} 

あなたは本当に（この場合は、実際に不要である）キーを使用する場合は、常に代わりに同様の方法でのHashSetのHashMapを実装することができます。それぞれのコンストラクタにキーを渡すことを忘れないでください。

Answer 2

は、私はクラスBとCの抱き合わせが好きではありませんfoo_inst.b_queue.removeを使用してFooに渡します。これにより、アーキテクチャが緊密に結合されます。インタフェースやその他の抽象化メカニズムによってこれを避けるようにしてください。

可能なコヒーレンシーの問題を特定しました。いくつかのロック、使用前にチェックするか、ダブル除去を避けるための他のメカニズム。あなただけHashSetsを使用していないのはなぜおそらく

if (foo_inst.b_queue.contains(this) ) 
{ 
    foo_inst.b_queue.remove(this); 
}