@@ -34,9 +34,9 @@ public class SparkOdometryThread {
3434 private final List <SparkBase > sparks = new ArrayList <>();
3535 private final List <DoubleSupplier > sparkSignals = new ArrayList <>();
3636 private final List <DoubleSupplier > genericSignals = new ArrayList <>();
37- private final List <Queue <Double >> sparkQueues = new ArrayList <>();
38- private final List <Queue <Double >> genericQueues = new ArrayList <>();
39- private final List <Queue <Double >> timestampQueues = new ArrayList <>();
37+ private final List <ArrayBlockingQueue <Double >> sparkQueues = new ArrayList <>();
38+ private final List <ArrayBlockingQueue <Double >> genericQueues = new ArrayList <>();
39+ private final List <ArrayBlockingQueue <Double >> timestampQueues = new ArrayList <>();
4040
4141 private static SparkOdometryThread instance = null ;
4242 private Notifier notifier = new Notifier (this ::run );
@@ -60,7 +60,7 @@ public void start() {
6060
6161 /** Registers a Spark signal to be read from the thread. */
6262 public Queue <Double > registerSignal (SparkBase spark , DoubleSupplier signal ) {
63- Queue <Double > queue = new ArrayBlockingQueue <>(20 );
63+ ArrayBlockingQueue <Double > queue = new ArrayBlockingQueue <>(20 );
6464 Drive .odometryLock .lock ();
6565 try {
6666 sparks .add (spark );
@@ -74,7 +74,7 @@ public Queue<Double> registerSignal(SparkBase spark, DoubleSupplier signal) {
7474
7575 /** Registers a generic signal to be read from the thread. */
7676 public Queue <Double > registerSignal (DoubleSupplier signal ) {
77- Queue <Double > queue = new ArrayBlockingQueue <>(20 );
77+ ArrayBlockingQueue <Double > queue = new ArrayBlockingQueue <>(20 );
7878 Drive .odometryLock .lock ();
7979 try {
8080 genericSignals .add (signal );
@@ -87,7 +87,7 @@ public Queue<Double> registerSignal(DoubleSupplier signal) {
8787
8888 /** Returns a new queue that returns timestamp values for each sample. */
8989 public Queue <Double > makeTimestampQueue () {
90- Queue <Double > queue = new ArrayBlockingQueue <>(20 );
90+ ArrayBlockingQueue <Double > queue = new ArrayBlockingQueue <>(20 );
9191 Drive .odometryLock .lock ();
9292 try {
9393 timestampQueues .add (queue );
0 commit comments