LinkedBlockingQueueのプログラムをArrayBlockingQueueのプログラムにしたい

Question

前提・実現したいこと

下記のプログラムはLinkedBlockingQueueを使用して作ったものだが、それをArrayBlockingQueueを使用したプログラムに修正したい

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ArrayBlockingQueue;
import javafx.scene.paint.Color;
import tg.Turtle;
import tg.TurtleFrame;
public class BlokingQueueSimulation  {
	BlockingQueue<Turtle> queue = new LinkedBlockingQueue<Turtle>();
	TurtleFrame f = new TurtleFrame();
	public static void main(String[] args) {
		new BlokingQueueSimulation().start();
	}
	void start() {
		new Thread(new TurtleProducer(10, 50.0)).start();
		new Thread(new TurtleProducer(10, 200.0)).start();
		new Thread(new TurtleProducer(10, 300.0)).start();
		new Thread(new TurtleConsumer(20, 200.0)).start();
		new Thread(new TurtleConsumer(10, 400.0)).start();
	}
	class TurtleProducer implements Runnable {
		private int n = 0;
		private double ypos = 200.0;
		final double xpos = 50.0;
		TurtleProducer(int n, double ypos) {
			this.n = n; this.ypos = ypos;
		}
		public void run() {
			for(int i = 0; i < n; i++) {
				Turtle t = new Turtle(xpos, ypos, 90.0);
				f.add(t);
				int speed = (int)((Math.sin(i / 3.0) + 1.5) * 50.0);
				t.speed(speed);
				t.setTScale((i+1.0)/20.0);
				t.setTColor(Color.BLUE);
				t.moveTo(200.0, 200.0);
				t.setTColor(Color.BLACK);
				try {
					queue.add(t); // タートルをキューに追加する
				} catch(Exception e) { }
			}
		}
	}
	class TurtleConsumer implements Runnable {
		private int n = 0;
		private double ypos = 200.0;
		final double xpos = 350.0;
		TurtleConsumer(int n, double ypos) {
			this.n = n; this.ypos = ypos;
		}
		public void run() {
			for(int i = 0; i < n; i++) {
				try {
					Turtle t = queue.element(); // タートルをキューから取り出す
					int speed = (int)((-Math.cos(i / 3.0) + 1.5) * 50.0);
					t.speed(speed);
					t.setTColor(Color.RED);
					t.moveTo(xpos, ypos);
					f.remove(t);
				}catch(Exception e) { }
			}
		}
	}
}

試したこと

BlockingQueue<Turtle> queue = new LinkedBlockingQueue<Turtle>();

この部分を

BlockingQueue<Turtle> queue = new ArrayBlockingQueue<Turtle>(1);

に変更した

予想していること

queue.add(t); // タートルをキューに追加する

Turtle t = queue.element(); // タートルをキューから取り出す

この二つをArrayで使いやすいように変更する必要がある？
自分ができるなりに調べたり教科書を見直すなどしたのですが、解決法が一向に思い浮かびませんでした

教科書

https://www.i.h.kyoto-u.ac.jp/users/tsuiki/javaEveryone3/index.html

Comments

[swordone]

問題が何か不明なのに、何の「解決法」を探しているのかが全く分かりません。
実際に書き換えて、こういう問題が出たから解決したい、というのならわかりますが。

Answer 1

Turtle t=queue.take()
に変更したらできました