Очередь Java, массивы и JNI

Я думаю, что это - общий вопрос о Java, но он действительно включает некоторый материал Android.

Таким образом, вот соглашение: у меня есть перенесенная версия JNI MPG123 для Android, и я могу вытянуть данные PCM из файла MP3 на SDCard. Я хотел бы вытянуть блок эти данные, сделать анализ его с помощью другого класса, который я записал, затем продвиньте его в очередь. Идеально, я хотел бы, чтобы аудио воспроизвело с четырехсекундной задержкой. Я достиг его без задержки с помощью этого кода:

public void run() 
{
  // The actual thread where the PCM data gets processed and analyzed
 short[] pcm = new short[ 4096 ];
 short[] zero = new short[ 4096 ];
 Queue<short[]> buffer = new LinkedList<short[]>();

 // Fill the zero buffer
 for( int i = 0; i < 4096; i++ )
  zero[i] = 0;

 // Push back 4 seconds of silence - Note this commented section
 //for( int i = 0; i < 43; i++ )
 // buffer.add( zero );

 // Analyze the whole file 
 while( !isInterrupted() )
 {
  // Grab and analyze data, add events
  int ret = audio.GetPCM( pcm );
  //Log.d( "AudioThread", "GetPCM returns: " + ret );
  if( ret != MPG123.MPG123_DONE )
  {
   // Process the PCM data
   if( bd.Process( pcm ) != BeatDetection.AUDALYSIS_OK )
    Log.v( "AudioThread", "Beat Detection Error!" );

   // Add the data to the PCM buffer
   buffer.add( pcm );
  }

  // Play the audio
  short[] data = buffer.poll();
  if( data != null ) // If we have data left in the buffer
   at.write( data, 0, 4096 ); // Write it to the audio track
  else
   break; // Otherwise we need to exit the loop

  Log.d( "AudioThread", "BufferSize= " + buffer.size() );
 }

 // Debug message
 Log.d( "AudioThread", "Exiting Thread." );

 // Clean stuff up
 bd.Cleanup();
 audio.Cleanup();
 at.stop();
 at.release(); 
 }

Тем не менее, когда я пытаюсь ввести задержку в свою очередь путем добавления "4 секунд" ценность 0 в очередь (Отметьте прокомментированный блок), мои музыкальные игры сразу же, но запускает 4 секунды в песню и играет в в реальном времени, пока очередь не начинает пустеть, где она играет тот же блок много раз до убегающий из цикла. Почти кажется, как будто очередь действует как очередь "Первым пришел - последним вышел", а не очередь "Метода"первым пришел - первым вышел"".

Возможно, я не использую Очередь Java правильно? Возможно, это - некоторая нечетная ошибка с android AudioTrack?

Спасибо!

- Griff

РЕДАКТИРОВАНИЕ - я решил проблему. Это, кажется, проблема с моей реализацией JNI GetPCM. Кажется, что, когда я скопировал данные в PCM от уровня JNI, это установило те же данные для каждого экземпляра PCM, пододвинутой обратно в очередь, установив каждую запись PCM в очереди к тому же кадру данных PCM. Я решил проблему путем изменения:

buffer.add( pcm );

кому:

buffer.add( pcm.clone() );

Новый Вопрос: это нормальное поведение Java? Я реализовывал функцию JNI неправильно?

JNIEXPORT jint JNICALL Java_com_motalenbubble_projectlucid_MPG123_GetPCM(
    JNIEnv* env,
    jobject obj,
    jshortArray data ) // jshortarray already has a size attribute
{
    // Call mpg123_read
    jint  err  = MPG123_OK, length;
    jshort *pcm;
    jsize len = (*env)->GetArrayLength( env, data );

    pcm = (*env)->GetShortArrayElements( env, data, NULL );
    err = mpg123_read( mh, (unsigned char*)pcm, len * sizeof( short ), &length ); // Read length is in bytes - we need in shorts. 
    (*env)->ReleaseShortArrayElements( env, data, pcm, 0 );
    // Annoying logging
    //dprintf(0, "read(%d): %s\n", length, err == MPG123_ERR ? mpg123_strerror(mh) : mpg123_plain_strerror(err)); 
    return err;
}