andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Use LinkedTransferQueue that ships with java7 when running on java >= 7. See #273

Browse Source
This commit is contained in:
Norman Maurer 2012-04-19 13:24:46 +02:00
parent 1a53f9e0bd
commit 1779032218
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/jboss/netty/util/internal/QueueFactory.java
View File

@ -42,6 +42,12 @@ public final class QueueFactory {
* @return queue the {@link BlockingQueue} implementation * @return queue the {@link BlockingQueue} implementation
*/ */
public static <T> BlockingQueue<T> createQueue(Class<T> itemClass) { public static <T> BlockingQueue<T> createQueue(Class<T> itemClass) {
// if we run in java >=7 its the best to just use the LinkedTransferQueue which
// comes with java bundled. See #273
if (DetectionUtil.javaVersion() >= 7) {
return new java.util.concurrent.LinkedTransferQueue<T>();
}
try { try {
if (useUnsafe) { if (useUnsafe) {
return new LinkedTransferQueue<T>(); return new LinkedTransferQueue<T>();
@ -68,6 +74,12 @@ public final class QueueFactory {
* @return queue the {@link BlockingQueue} implementation * @return queue the {@link BlockingQueue} implementation
*/ */
public static <T> BlockingQueue<T> createQueue(Collection<? extends T> collection, Class<T> itemClass) { public static <T> BlockingQueue<T> createQueue(Collection<? extends T> collection, Class<T> itemClass) {
// if we run in java >=7 its the best to just use the LinkedTransferQueue which
// comes with java bundled. See #273
if (DetectionUtil.javaVersion() >= 7) {
return new java.util.concurrent.LinkedTransferQueue<T>();
}
try { try {
if (useUnsafe) { if (useUnsafe) {
return new LinkedTransferQueue<T>(collection); return new LinkedTransferQueue<T>(collection);