equal
deleted
inserted
replaced
58 queues.add(new ConcurrentLinkedQueue<Integer>()); |
58 queues.add(new ConcurrentLinkedQueue<Integer>()); |
59 queues.add(new ArrayBlockingQueue<Integer>(items, false)); |
59 queues.add(new ArrayBlockingQueue<Integer>(items, false)); |
60 //queues.add(new ArrayBlockingQueue<Integer>(count, true)); |
60 //queues.add(new ArrayBlockingQueue<Integer>(count, true)); |
61 queues.add(new LinkedBlockingQueue<Integer>()); |
61 queues.add(new LinkedBlockingQueue<Integer>()); |
62 queues.add(new LinkedBlockingDeque<Integer>()); |
62 queues.add(new LinkedBlockingDeque<Integer>()); |
63 // queues.add(new LinkedTransferQueue<Integer>()); |
63 queues.add(new LinkedTransferQueue<Integer>()); |
64 |
64 |
65 // Following additional implementations are available from: |
65 // Following additional implementations are available from: |
66 // http://gee.cs.oswego.edu/dl/concurrency-interest/index.html |
66 // http://gee.cs.oswego.edu/dl/concurrency-interest/index.html |
67 // queues.add(new SynchronizedLinkedListQueue<Integer>()); |
67 // queues.add(new SynchronizedLinkedListQueue<Integer>()); |
68 |
68 |