Changeset 526 for Tests


Ignore:
Timestamp:
04/01/12 17:17:31 (10 years ago)
Author:
BegemoT
Message:
 
File:
1 copied

Legend:

Unmodified
Added
Removed
  • Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/impl/DummyQueue.java

    r524 r526  
    11package test.threads.queue.unstressed.impl; 
    22 
    3 import java.util.concurrent.ArrayBlockingQueue; 
    4  
     3import test.threads.queue.stressed.cpu.LongValueMessage; 
    54import test.threads.queue.unstressed.IBoundedQueueFactory; 
    65import test.threads.queue.unstressed.IQueue; 
    76 
    87/** 
    9  * Самый базовый вариант, адаптер ABQ к интерфейсу IQueue. 
     8 * Фальшивая реализация -- для измерения погрешностей, вносимых в измерения 
     9 * нашей инфраструктурой 
    1010 * 
    1111 * @author cheremin 
    1212 * @since 22.09.11,  13:09 
    1313 */ 
    14 public class ABQWrapperQueue<T> implements IQueue<T> { 
     14public class DummyQueue<T> implements IQueue<T> { 
    1515 
    16     private final ArrayBlockingQueue<T> queue; 
     16    private final LongValueMessage message = new LongValueMessage( 42 ); 
    1717 
    18     public ABQWrapperQueue( final int size ) { 
    19         this.queue = new ArrayBlockingQueue<T>( size ); 
     18    public DummyQueue( final int size ) { 
    2019    } 
    2120 
    2221    @Override 
    2322    public void enqueue( final T item ) throws InterruptedException { 
    24         queue.put( item ); 
    2523    } 
    2624 
    2725    @Override 
    2826    public T dequeue() throws InterruptedException { 
    29         return queue.take(); 
     27        return ( T ) message; 
    3028    } 
    3129 
    3230    @Override 
    3331    public int size() { 
    34         return queue.size(); 
     32        return 0; 
    3533    } 
    3634 
    3735    @SuppressWarnings( "unchecked" ) 
    38     public static <T> IBoundedQueueFactory<T, ABQWrapperQueue<T>> factory() { 
     36    public static <T> IBoundedQueueFactory<T, DummyQueue<T>> factory() { 
    3937        return FACTORY; 
    4038    } 
    4139 
    42     public static final IBoundedQueueFactory FACTORY = new IBoundedQueueFactory<Object, ABQWrapperQueue<Object>>() { 
     40    public static final IBoundedQueueFactory FACTORY = new IBoundedQueueFactory<Object, DummyQueue<Object>>() { 
    4341        @Override 
    44         public ABQWrapperQueue<Object> create( final int size ) { 
    45             return new ABQWrapperQueue<Object>( size ); 
     42        public DummyQueue<Object> create( final int size ) { 
     43            return new DummyQueue<Object>( size ); 
    4644        } 
    4745 
    4846        @Override 
    4947        public String toString() { 
    50             return "ABQWrapperFactory"; 
     48            return "DummyFactory"; 
    5149        } 
    5250    }; 
Note: See TracChangeset for help on using the changeset viewer.