From 211fd778ac9011ec79d745767b7d23c8de738003 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Tue, 31 Jan 2012 10:51:12 +0100
Subject: =?UTF-8?q?WorkList=20=3D>=20WorkQueue=20=E2=80=93=20A=20worker=20?=
 =?UTF-8?q?thread=20helper=20class.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../test/java/com/orbekk/util/WorkQueueTest.java   | 37 ++++++++++++++++++++++
 1 file changed, 37 insertions(+)
 create mode 100644 same/src/test/java/com/orbekk/util/WorkQueueTest.java

(limited to 'same/src/test/java/com/orbekk/util/WorkQueueTest.java')

diff --git a/same/src/test/java/com/orbekk/util/WorkQueueTest.java b/same/src/test/java/com/orbekk/util/WorkQueueTest.java
new file mode 100644
index 0000000..ab6e138
--- /dev/null
+++ b/same/src/test/java/com/orbekk/util/WorkQueueTest.java
@@ -0,0 +1,37 @@
+package com.orbekk.util;
+
+import static org.junit.Assert.*;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Test;
+
+public class WorkQueueTest {   
+    @Test
+    public void testPerformsWork() throws Exception {
+        final ArrayList<Integer> doubled = new ArrayList<Integer>();
+        WorkQueue<Integer> worker = new WorkQueue<Integer>() {
+            @Override protected void onChange() {
+                List<Integer> list = getAndClear();
+                for (int x : list) {
+                    doubled.add(x * 2);
+                }
+                synchronized (doubled) {
+                    doubled.notifyAll();
+                }
+            }
+        };
+        
+        synchronized (doubled) {
+            worker.start();
+            worker.add(1);
+            doubled.wait();
+            worker.interrupt();
+        }
+        
+        worker.join();
+        assertEquals(2, (int)doubled.get(0));
+    }
+
+}
-- 
cgit v1.2.3