Searched refs:queues (Results 1 – 1 of 1) sorted by relevance
48 List<SynchronousQueue<Boolean>> queues = new ArrayList<SynchronousQueue<Boolean>>( in main() local51 queues.add(new SynchronousQueue<Boolean>()); in main()55 threads[i] = new Thread(new Main(i, queues.get(i), queues.get((i + 1) % threads.length), in main()63 checkTimeout(queues.get(0).offer(Boolean.TRUE, TIMEOUT_VALUE, TimeUnit.MINUTES)); in main()