Java ConcurrentMap - マップ内のキーの位置

Question

私は面白い問題があります。私はいくつかの助けが必要です。私はFIFOと他の自然順序のキー（ConcurrentMap）に基づいた2つの別々の条件の2つのキューを実装しました。つまり、両方のキューに同じデータが異なる順序で配置されたイメージを作成できます。いくつかの基準に基づいてConcurrentMapのキーを見つけると、FIFOマップ内のキーの「位置」を見つける最良の方法は何か、私が持っている質問（そしてこれを行う効率的な方法を探しています）です。本質的に私はそれが最初のキー（これは簡単です）か、それとも10番目のキーかを知りたいと思います。

ご協力いただければ幸いです。

Answer 1

私は以下のコードのようなものが仕事をすると信じています。抽象メソッドとしてelement - > keyの実装を残しました。カウンタが増加する数を要素に割り当てるために使用されていることに注意してください。また、add(...)が複数のスレッドによって呼び出されている場合、FIFO内の要素は緩やかに順序付けされるだけであることにも注意してください。それは豪華なmax(...)とmin(...)ロジックを強制します。またその理由は、およそです。最初と最後は特殊なケースです。最初に明確に示すことができます。現在の実装が実際のインデックスを返すため、最後は扱いにくいです。

これはおおよその場所なので、0.0と1.0の間のAPIをfloatに戻して、キュー内の相対位置を示すことを検討することをおすすめします。あなたのコードがpop(...)以外のいくつかの手段を用いて除去することをサポートする必要がある場合

、あなたはすべての適切なint/floatキャスト&丸めて、おおよそのサイズを使用し、((id - min)/(max - min)) * sizeへの復帰を変更する必要があります。

public abstract class ApproximateLocation<K extends Comparable<K>, T> { 

    protected abstract K orderingKey(T element); 

    private final ConcurrentMap<K, Wrapper<T>> _map = new ConcurrentSkipListMap<K, Wrapper<T>>(); 
    private final Deque<Wrapper<T>> _fifo = new LinkedBlockingDeque<Wrapper<T>>(); 
    private final AtomicInteger _counter = new AtomicInteger(); 

    public void add(T element) { 
     K key = orderingKey(element); 
     Wrapper<T> wrapper = new Wrapper<T>(_counter.getAndIncrement(), element); 
     _fifo.add(wrapper); 
     _map.put(key, wrapper); 
    } 

    public T pop() { 
     Wrapper<T> wrapper = _fifo.pop(); 
     _map.remove(orderingKey(wrapper.value)); 
     return wrapper.value; 
    } 

    public int approximateLocation(T element) { 
     Wrapper<T> wrapper = _map.get(orderingKey(element)); 
     Wrapper<T> first = _fifo.peekFirst(); 
     Wrapper<T> last = _fifo.peekLast(); 
     if (wrapper == null || first == null || last == null) { 
      // element is not in composite structure; fifo has not been written to yet because of concurrency 
      return -1; 
     } 
     int min = Math.min(wrapper.id, Math.min(first.id, last.id)); 
     int max = Math.max(wrapper.id, Math.max(first.id, last.id)); 
     if (wrapper == first || max == min) { 
      return 0; 
     } 
     if (wrapper == last) { 
      return max - min; 
     } 
     return wrapper.id - min; 
    } 

    private static class Wrapper<T> { 
     final int id; 
     final T value; 

     Wrapper(int id, T value) { 
      this.id = id; 
      this.value = value; 
     } 
    } 
} 

Answer 2

FIFOマップの順序にアクセスするためのAPIはありません。あなたができる唯一の方法は、keySet()、values()またはentrySet()以上の繰り返しです。

Answer 3

ConcurrentNavigableMapを使用できる場合、headMapのサイズは、まさにあなたが望むものを提供します。