fix:优化

Author: joshua.shi

concurrency/src/main/java/com/javaedge/concurrency/HttpFilter.java

@@ -1,6 +1,6 @@
 package com.javaedge.concurrency;
 
-import com.javaedge.concurrency.example.threadLocal.RequestHolder;
+import com.javaedge.concurrency.threadLocal.RequestHolder;
 import lombok.extern.slf4j.Slf4j;
 
 import javax.servlet.Filter;

concurrency/src/main/java/com/javaedge/concurrency/HttpInterceptor.java

@@ -1,6 +1,6 @@
 package com.javaedge.concurrency;
 
-import com.javaedge.concurrency.example.threadLocal.RequestHolder;
+import com.javaedge.concurrency.threadLocal.RequestHolder;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
 

concurrency/src/main/java/com/javaedge/concurrency/example/LockSupportBlockerTest.java renamed to concurrency/src/main/java/com/javaedge/concurrency/LockSupportBlockerTest.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example;
+package com.javaedge.concurrency;
 
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.LockSupport;

concurrency/src/main/java/com/javaedge/concurrency/example/LockSupportTest.java renamed to concurrency/src/main/java/com/javaedge/concurrency/LockSupportTest.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example;
+package com.javaedge.concurrency;
 
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.LockSupport;

concurrency/src/main/java/com/javaedge/concurrency/example/UnsafeTest.java renamed to concurrency/src/main/java/com/javaedge/concurrency/UnsafeTest.java

@@ -1,26 +1,26 @@
-package com.javaedge.concurrency.example;
+package com.javaedge.concurrency;
 
 import sun.misc.Unsafe;
 
 import java.lang.reflect.Field;
 import java.util.concurrent.TimeUnit;
 
+/**
+ * @author apple
+ */
 public class UnsafeTest {
 
     public static void main(String[] args) throws NoSuchFieldException, IllegalAccessException {
         Field f = Unsafe.class.getDeclaredField("theUnsafe");
         f.setAccessible(true);
         Unsafe unsafe = (Unsafe) f.get(null);
-        Thread t1 = new Thread() {
-            @Override
-            public void run() {
-                Thread.currentThread().setName("t1");
-                System.out.println(Thread.currentThread().getName() + " before park");
-                //park 100 seconds
-                unsafe.park(false, TimeUnit.NANOSECONDS.convert(100, TimeUnit.SECONDS));
-                System.out.println(Thread.currentThread().getName() + " after park");
-            }
-        };
+        Thread t1 = new Thread(() -> {
+            Thread.currentThread().setName("t1");
+            System.out.println(Thread.currentThread().getName() + " before park");
+            //park 100 seconds
+            unsafe.park(false, TimeUnit.NANOSECONDS.convert(100, TimeUnit.SECONDS));
+            System.out.println(Thread.currentThread().getName() + " after park");
+        });
         Thread t2 = new Thread() {
             @Override
             public void run() {

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/CountDownLatchExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/CountDownLatchExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs;
+package com.javaedge.concurrency.aqs;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/CountDownLatchExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/CountDownLatchExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs;
+package com.javaedge.concurrency.aqs;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/CyclicBarrierExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/CyclicBarrierExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs;
+package com.javaedge.concurrency.aqs;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/CyclicBarrierExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/CyclicBarrierExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs;
+package com.javaedge.concurrency.aqs;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/CyclicBarrierExample3.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/CyclicBarrierExample3.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs;
+package com.javaedge.concurrency.aqs;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/SampleLock.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/SampleLock.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs;
+package com.javaedge.concurrency.aqs;
 
 /**
  * @author JavaEdge

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/SimpleLock.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/SimpleLock.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs;
+package com.javaedge.concurrency.aqs;
 
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.AbstractQueuedSynchronizer;

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/MicrowaveOvenPool.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/MicrowaveOvenPool.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import javax.validation.constraints.NotNull;
 import java.util.List;

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/ObjPool.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/ObjPool.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/SemaphoreExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/SemaphoreExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/SemaphoreExample3.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample3.java

@@ -1,11 +1,10 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Semaphore;
-import java.util.concurrent.TimeUnit;
 
 @Slf4j
 public class SemaphoreExample3 {

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/SemaphoreExample4.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample4.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import lombok.extern.slf4j.Slf4j;
 

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/SemaphoreExample5.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample5.java

@@ -1,12 +1,8 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.Queue;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Semaphore;
-import java.util.concurrent.TimeUnit;
 
 /**
  * @author JavaEdge

concurrency/src/main/java/com/javaedge/concurrency/example/aqs/semaphore/SemaphoreExample6.java renamed to concurrency/src/main/java/com/javaedge/concurrency/aqs/semaphore/SemaphoreExample6.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.aqs.semaphore;
+package com.javaedge.concurrency.aqs.semaphore;
 
 import java.util.concurrent.Semaphore;
 

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/AtomicExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/AtomicExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/AtomicExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/AtomicExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/AtomicExample3.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/AtomicExample3.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/AtomicExample4.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/AtomicExample4.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/AtomicExample5.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/AtomicExample5.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.Getter;

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/AtomicExample6.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/AtomicExample6.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/AtomicTest.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/AtomicTest.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import java.util.concurrent.atomic.AtomicInteger;
 

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/LockCASDemo.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/LockCASDemo.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import sun.misc.Unsafe;
 

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/LongAccumulatorDemo.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/LongAccumulatorDemo.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import java.util.concurrent.atomic.LongAccumulator;
 import java.util.function.LongBinaryOperator;

concurrency/src/main/java/com/javaedge/concurrency/example/atomic/LongAdderDemo.java renamed to concurrency/src/main/java/com/javaedge/concurrency/atomic/LongAdderDemo.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.atomic;
+package com.javaedge.concurrency.atomic;
 
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.atomic.LongAdder;

concurrency/src/main/java/com/javaedge/concurrency/example/cache/CacheController.java renamed to concurrency/src/main/java/com/javaedge/concurrency/cache/CacheController.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.cache;
+package com.javaedge.concurrency.cache;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;

concurrency/src/main/java/com/javaedge/concurrency/example/cache/GuavaCacheExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/cache/GuavaCacheExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.cache;
+package com.javaedge.concurrency.cache;
 
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;

concurrency/src/main/java/com/javaedge/concurrency/example/cache/GuavaCacheExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/cache/GuavaCacheExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.cache;
+package com.javaedge.concurrency.cache;
 
 import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;

concurrency/src/main/java/com/javaedge/concurrency/example/cache/RedisClient.java renamed to concurrency/src/main/java/com/javaedge/concurrency/cache/RedisClient.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.cache;
+package com.javaedge.concurrency.cache;
 
 import org.springframework.stereotype.Component;
 import redis.clients.jedis.Jedis;

concurrency/src/main/java/com/javaedge/concurrency/example/cache/RedisConfig.java renamed to concurrency/src/main/java/com/javaedge/concurrency/cache/RedisConfig.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.cache;
+package com.javaedge.concurrency.cache;
 
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;

concurrency/src/main/java/com/javaedge/concurrency/common/Nap.java

@@ -0,0 +1,23 @@
+package com.javaedge.concurrency.common;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author JavaEdge
+ */
+public class Nap {
+
+    // Seconds
+    public Nap(double t) {
+        try {
+            TimeUnit.MILLISECONDS.sleep((int) (1000 * t));
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public Nap(double t, String msg) {
+        this(t);
+        System.out.println(msg);
+    }
+}

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/ArrayListExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/ArrayListExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.NotThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/DateFormatExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/DateFormatExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.NotThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/DateFormatExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/DateFormatExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/DateFormatExample3.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/DateFormatExample3.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/HashMapExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/HashMapExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.NotThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/HashSetExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/HashSetExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.NotThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/StringExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/StringExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.NotThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/commonunsafe/StringExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/commonunsafe/StringExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.commonunsafe;
+package com.javaedge.concurrency.commonunsafe;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/concurrent/ConcurrentHashMapExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/concurrent/ConcurrentHashMapExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.concurrent;
+package com.javaedge.concurrency.concurrent;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/concurrent/ConcurrentSkipListMapExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/concurrent/ConcurrentSkipListMapExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.concurrent;
+package com.javaedge.concurrency.concurrent;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/concurrent/ConcurrentSkipListSetExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/concurrent/ConcurrentSkipListSetExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.concurrent;
+package com.javaedge.concurrency.concurrent;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/concurrent/CopyOnWriteArrayListExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/concurrent/CopyOnWriteArrayListExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.concurrent;
+package com.javaedge.concurrency.concurrent;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/concurrent/CopyOnWriteArraySetExample.java renamed to concurrency/src/main/java/com/javaedge/concurrency/concurrent/CopyOnWriteArraySetExample.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.concurrent;
+package com.javaedge.concurrency.concurrent;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/condition/BlockedQueue.java renamed to concurrency/src/main/java/com/javaedge/concurrency/condition/BlockedQueue.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.condition;
+package com.javaedge.concurrency.condition;
 
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.Lock;

concurrency/src/main/java/com/javaedge/concurrency/example/condition/DubboCondition.java renamed to concurrency/src/main/java/com/javaedge/concurrency/condition/DubboCondition.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.condition;
+package com.javaedge.concurrency.condition;
 
 import redis.clients.jedis.Response;
 

concurrency/src/main/java/com/javaedge/concurrency/example/count/CountExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/count/CountExample1.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.count;
+package com.javaedge.concurrency.count;
 
 import com.javaedge.concurrency.annoations.NotThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/count/CountExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/count/CountExample2.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.count;
+package com.javaedge.concurrency.count;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/count/CountExample3.java renamed to concurrency/src/main/java/com/javaedge/concurrency/count/CountExample3.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.count;
+package com.javaedge.concurrency.count;
 
 import com.javaedge.concurrency.annoations.ThreadSafe;
 import lombok.extern.slf4j.Slf4j;

concurrency/src/main/java/com/javaedge/concurrency/example/count/CountExample4.java renamed to concurrency/src/main/java/com/javaedge/concurrency/count/CountExample4.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.count;
+package com.javaedge.concurrency.count;
 
 import com.javaedge.concurrency.annoations.NotThreadSafe;
 import lombok.extern.slf4j.Slf4j;