Spliteratorを使用してConcurrentLinkedQueueを半分に分割します

Question

私はConcurrentLinkedQueueを持っています。これを2つの半分に分割し、それぞれ別々の2つのスレッドで処理します。 Spliteratorを使用しようとしましたが、パーティション化されたキューを取得する方法がわかりません。

ConcurrentLinkedQueue<int[]> q = // contains a large number of elements 
Spliterator<int[]> p1 = q.spliterator(); 
Spliterator<int[]> p2 = p1.trySplit(); 
p1.getQueue(); 
p2.getQueue(); 

私は私がそれを行うための正しい方法を教えてくださいしたいが、など

p1.getQueue()を行うことはできません。

Answer 1

一般的に半分に分割することはできません。半分に分割することを意味します。このキューは、各時点でサイズを持つ必要があります。そしてCLQはsize()メソッドを持っていますが、このサイズにはO(n)のトラバーサル時間が必要であることは明らかです。これはconcurrent queueなので、サイズは全く正確ではないかもしれません（結局理由はconcurrentです。現在SpliteratorからCLQまでは、私が見ることができるものからバッチでそれを分割します。

あなたは要素を論理的に半分に分割して処理したい場合は、私は非常に分割されますdrainTo方法を持っているいくつかのBlocking実装、あなたが例えばArrayListに要素を排出でき、このように移動することをお勧めより良い（半分、次に半分など）。

なぜ、別のスレッドで処理したいのですか？これは非常に直観的なようですが、Spliteratorは並列ストリームで動作するように設計されています。 trySplitを一度と呼ぶのは、おそらく十分ではありません。返信するまで呼び出さなければなりません。null ...いずれにしても、自分自身でこれらのことをするのは、とても悪い考えです。