volatile

Author: FlammulinaBlog

JavaConcurrent/.settings/org.eclipse.jdt.core.prefs

@@ -1,5 +1,13 @@
 eclipse.preferences.version=1
-org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.5
-org.eclipse.jdt.core.compiler.compliance=1.5
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.methodParameters=do not generate
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
 org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
-org.eclipse.jdt.core.compiler.source=1.5
+org.eclipse.jdt.core.compiler.source=1.8

JavaConcurrent/src/main/java/com/FlammulinaBlog/Java/Concurrent/BoundedHashSet.java renamed to JavaConcurrent/src/main/java/com/FlammulinaBlog/Java/Concurrent/Semaphore/SemaphoreTest.java

@@ -1,4 +1,4 @@
-package com.FlammulinaBlog.Java.Concurrent;
+package com.FlammulinaBlog.Java.Concurrent.Semaphore;
 
 import java.util.Collections;
 import java.util.HashSet;
@@ -11,12 +11,12 @@
  * <p/>
  * @author flammulinaBlog
  */
-public class BoundedHashSet<T> {
+public class SemaphoreTest<T> {
 
     private final Set<T> set;
     private final Semaphore sem;
 
-    public BoundedHashSet(int bound) {
+    public SemaphoreTest(int bound) {
         this.set = Collections.synchronizedSet(new HashSet<T>());
         this.sem = new Semaphore(bound);
     }
@@ -48,7 +48,7 @@ public boolean remove(T o) {
     @SuppressWarnings({ "unchecked", "rawtypes" })
 	public static void main(String[] args) {
 
-    	BoundedHashSet test=new BoundedHashSet(1);
+    	SemaphoreTest test=new SemaphoreTest(1);
     	try {
 			if(test.add("new")) {
 				test.remove("new");

JavaConcurrent/src/main/java/com/FlammulinaBlog/Java/Concurrent/Volatile/VolatileTest.java

@@ -0,0 +1,78 @@
+package com.FlammulinaBlog.Java.Concurrent.Volatile;
+
+/**
+ * volatile 保持一致
+ * @author flammulinaBlog
+ */
+public class VolatileTest implements Runnable {
+    private volatile int firstVal;
+
+    private volatile int secondVal;
+
+    @Override
+    public void run() {
+
+    }
+
+    public boolean valEqual() {
+        return firstVal == secondVal;
+    }
+
+    @SuppressWarnings("unused")
+	private void workMethod() {
+        int val = 1;
+        while (true) {
+            stepOne(val);
+            stepTwo(val);
+            val++;
+            try {
+                Thread.sleep(200);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+
+    }
+
+
+    //赋值后，休眠300毫秒，从而使线程有机会在stepOne操作和stepTwo操作之间被挂起
+    private void stepOne(int newVal) {
+        firstVal = newVal;
+        try {
+            //模拟长时间运行的情况
+            Thread.sleep(300);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private void stepTwo(int newVal) {
+        secondVal = newVal;
+    }
+
+    public static void main(String[] args) {
+        VolatileTest dsr = new VolatileTest();
+        Thread t = new Thread(dsr);
+        t.start();
+
+        //休眠1秒，让其他线程有机会获得执行
+        try {
+            Thread.sleep(1000);
+        } catch (InterruptedException x) {
+        }
+        for (int i = 0; i < 10; i++) {
+            //挂起线程
+//            t.suspend();
+            System.out.println("dsr.valEqual()=" + dsr.valEqual());
+            //恢复线程
+//            t.resume();
+            try {
+                //线程随机休眠0~2秒
+                Thread.sleep((long) (Math.random() * 2000.0));
+            } catch (InterruptedException x) {
+                //略
+            }
+        }
+        System.exit(0); //中断应用程序
+    }
+}

JavaConcurrent/target/classes/META-INF/maven/com.FlammulinaBlog/JavaConcurrent/pom.properties

@@ -1,7 +1,7 @@
 #Generated by Maven Integration for Eclipse
-#Tue Dec 26 15:32:42 CST 2017
+#Tue Dec 26 16:02:53 CST 2017
 version=0.0.1
 groupId=com.FlammulinaBlog
 m2e.projectName=JavaConcurrent
-m2e.projectLocation=G\:\\workspace_4.7\\JavaConcurrent
+m2e.projectLocation=G\:\\workspace_4.7\\Java-Concurrent\\JavaConcurrent
 artifactId=JavaConcurrent