org.apache.maven.plugin.surefire.util.internal

Class FunkyTwoThreadBlockingQueue

java.lang.Object

org.apache.maven.plugin.surefire.util.internal.FunkyTwoThreadBlockingQueue

All Implemented Interfaces:

BlockingQueue

public class FunkyTwoThreadBlockingQueue
extends Object
implements BlockingQueue

A producer/consumer queue that is optimized for *one* producer thread and *one* consumer thread, and solely optimized for efficient inserts by the producer, minimizing producer locking for hand-off to a second consumer.

TwoThreadBlockingQueue insert 5000000 elements in = 52 FunkyTwoThreadBlockingQueue insert 5000000 elements in = 42 TwoThreadBlockingQueue produced and taken 5000000 elements in = 104 LinkedBlockingQueue insert 5000000 elements in = 1815 LinkedBlockingDeque insert 5000000 elements in = 113 ArrayList insert 5000000 elements in = 18 LinkedList insert 5000000 elements in = 334

Todo: Determine if this design actually works ;)

Author:

Kristian Rosenvold

Constructor Summary

Constructors

Constructor and Description
FunkyTwoThreadBlockingQueue()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(String object)
void	put(String object)
String	take()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FunkyTwoThreadBlockingQueue

public FunkyTwoThreadBlockingQueue()

Method Detail

put

public void put(String object)

add

public void add(String object)

Specified by:

add in interface BlockingQueue

take

public String take()
            throws InterruptedException

Specified by:

take in interface BlockingQueue

Throws:

InterruptedException