1 files changed, 79 insertions, 0 deletions
diff --git a/src/de/fhswf/in/inf/java1/aufgabe10/LineWordCount.java b/src/de/fhswf/in/inf/java1/aufgabe10/LineWordCount.java
new file mode 100644
index 0000000..e4356a3
--- /dev/null
+++ b/src/de/fhswf/in/inf/java1/aufgabe10/LineWordCount.java
@@ -0,0 +1,79 @@
+/**
+ * 
+ */
+package de.fhswf.in.inf.java1.aufgabe10;
+
+import java.util.concurrent.ConcurrentSkipListMap;
+
+/**
+ * Counts the words in one line.
+ *
+ * @author $Author: $
+ * @version $Revision: $, $Date: $ UTC
+ */
+public class LineWordCount implements Runnable
+{
+
+   private String[] lineArray;
+
+   private ConcurrentSkipListMap<String, Integer> lineWordMap;
+
+   private static final Integer NEWVALUE = new Integer(1);
+
+   /**
+    * Creates the object which will be threaded.
+    *
+    * @param wordMap
+    *           The wordMap into which the counts should be added.
+    * @param line
+    *           The line to be counted.
+    */
+   public LineWordCount(ConcurrentSkipListMap<String, Integer> wordMap,
+         String line)
+   {
+      if (wordMap == null)
+      {
+         throw new IllegalArgumentException("WordMap can't be null.");
+      }
+      if (line == null)
+      {
+         throw new IllegalArgumentException("Line can't be null.");
+      }
+      if (line.isEmpty())
+      {
+         throw new IllegalArgumentException("Line can't be empty.");
+      }
+      lineWordMap = wordMap;
+      lineArray = line.split("[^\\p{IsAlphabetic}\\p{Digit}]+");
+   }
+
+   /*
+    * (non-Javadoc)
+    * 
+    * @see java.lang.Runnable#run()
+    */
+   @Override
+   public final void run()
+   {
+      for (String word : lineArray)
+      {
+         // Split creates empty String, if first char is a split char.
+         if (!word.isEmpty())
+         {
+            word = word.toLowerCase();
+            boolean success;
+
+            do
+            {
+               success = true;
+               Integer tmp = lineWordMap.putIfAbsent(word, NEWVALUE);
+               if (tmp != null)
+               {
+                  success = lineWordMap.replace(word, tmp, tmp + 1);
+               }
+            }
+            while (!success);
+         }
+      }
+   }
+}