Concurrency

Author: turingfly

Java-8/src/concurrency/IntroducingThreads.java

@@ -85,7 +85,7 @@ public void understandingThreadConcurrency() {
 	 * java.lang.Runnable, or Runnable for short, is a functional interface that
 	 * takes no arguments and returns no data.
 	 * 
-	 * The Runnable interface is commonly used to defined the work a thread will
+	 * The Runnable interface is commonly used to define the work a thread will
 	 * execute, separate from the main application thread.
 	 * 
 	 * 

Java-8/src/concurrency/ManagingConcurrentProcesses.java

@@ -19,7 +19,7 @@ public class ManagingConcurrentProcesses {
 	/**
 	 * The CyclicBarrier takes in its constructors a limit value, indicating the
 	 * number of threads to wait for. As each thread nishes, it calls the
-	 * await() method on the cyclic barrier. Once the speci ed number of threads
+	 * await() method on the cyclic barrier. Once the specified number of threads
 	 * have each called await(), the barrier is released and all threads can
 	 * continue.
 	 */

Java-8/src/concurrency/UsingConcurrentCollections.java

@@ -62,19 +62,6 @@ public void blockingQueues() {
 			System.out.println(blockingDeque.pollLast(1, TimeUnit.SECONDS));
 		} catch (InterruptedException e) { // Handle interruption
 		}
-
-		try {
-			BlockingDeque<Integer> blockingDeque = new LinkedBlockingDeque<>();
-			blockingDeque.offer(91);
-			blockingDeque.offerFirst(5, 2, TimeUnit.MINUTES);
-			blockingDeque.offerLast(47, 100, TimeUnit.MICROSECONDS);
-			blockingDeque.offer(3, 4, TimeUnit.SECONDS);
-			System.out.println(blockingDeque.poll());
-			System.out.println(blockingDeque.poll(950, TimeUnit.MILLISECONDS));
-			System.out.println(blockingDeque.pollFirst(200, TimeUnit.NANOSECONDS));
-			System.out.println(blockingDeque.pollLast(1, TimeUnit.SECONDS));
-		} catch (InterruptedException e) { // Handle interruption
-		}
 	}
 
 	/**