Changeset 526 for Tests

Timestamp:

04/01/12 17:17:31 (10 years ago)

Author:

BegemoT

Message:

 

File:

• Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/impl/DummyQueue.java (copied) (copied from Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/impl/ABQWrapperQueue.java) (1 diff)

Tests/JAVA/test/src/main/java/test/threads/queue/unstressed/impl/DummyQueue.java

@@ -1 +1 @@
 package test.threads.queue.unstressed.impl;
 
-import java.util.concurrent.ArrayBlockingQueue;
-
+import test.threads.queue.stressed.cpu.LongValueMessage;
 import test.threads.queue.unstressed.IBoundedQueueFactory;
 import test.threads.queue.unstressed.IQueue;
 
 /**
- * Самый базовый вариант, адаптер ABQ к интерфейсу IQueue.
+ * Фальшивая реализация -- для измерения погрешностей, вносимых в измерения
+ * нашей инфраструктурой
  *
  * @author cheremin
  * @since 22.09.11,  13:09
  */
-public class ABQWrapperQueue<T> implements IQueue<T> {
+public class DummyQueue<T> implements IQueue<T> {
 
-    private final ArrayBlockingQueue<T> queue;
+    private final LongValueMessage message = new LongValueMessage( 42 );
 
-    public ABQWrapperQueue( final int size ) {
-        this.queue = new ArrayBlockingQueue<T>( size );
+    public DummyQueue( final int size ) {
     }
 
     @Override
     public void enqueue( final T item ) throws InterruptedException {
-        queue.put( item );
     }
 
     @Override
     public T dequeue() throws InterruptedException {
-        return queue.take();
+        return ( T ) message;
     }
 
     @Override
     public int size() {
-        return queue.size();
+        return 0;
     }
 
     @SuppressWarnings( "unchecked" )
-    public static <T> IBoundedQueueFactory<T, ABQWrapperQueue<T>> factory() {
+    public static <T> IBoundedQueueFactory<T, DummyQueue<T>> factory() {
         return FACTORY;
     }
 
-    public static final IBoundedQueueFactory FACTORY = new IBoundedQueueFactory<Object, ABQWrapperQueue<Object>>() {
+    public static final IBoundedQueueFactory FACTORY = new IBoundedQueueFactory<Object, DummyQueue<Object>>() {
         @Override
-        public ABQWrapperQueue<Object> create( final int size ) {
-            return new ABQWrapperQueue<Object>( size );
+        public DummyQueue<Object> create( final int size ) {
+            return new DummyQueue<Object>( size );
         }
 
         @Override
         public String toString() {
-            return "ABQWrapperFactory";
+            return "DummyFactory";
         }
     };