codingWang
diff --git a/‎bin/com/duwei/multythread/ReentrantLockDemo.class
1.34 KB b/‎bin/com/duwei/multythread/ReentrantLockDemo.class
1.34 KB
diff --git a/‎bin/com/duwei/multythread/ThreadDemo$1.class
789 Bytes b/‎bin/com/duwei/multythread/ThreadDemo$1.class
789 Bytes
diff --git a/‎bin/com/duwei/multythread/ThreadDemo.class
630 Bytes b/‎bin/com/duwei/multythread/ThreadDemo.class
630 Bytes
diff --git a/‎src/com/duwei/multythread/ReentrantLockDemo.java
Lines changed: 40 additions & 0 deletions b/‎src/com/duwei/multythread/ReentrantLockDemo.java
Lines changed: 40 additions & 0 deletions
diff --git a/‎src/com/duwei/multythread/ThreadDemo.java
Lines changed: 26 additions & 0 deletions b/‎src/com/duwei/multythread/ThreadDemo.java
Lines changed: 26 additions & 0 deletions
@@ -0,0 +1,40 @@
+package com.duwei.multythread;
+
+import java.util.concurrent.locks.ReentrantLock;
+/**
+ * 有两个线程都对i进行++操作，为了保证线程安全，
+ * 使用了 ReentrantLock，从用法上可以看出，
+ * 与 synchronized相比， ReentrantLock就稍微复杂一点。
+ * 因为必须在finally中进行解锁操作，如果不在 finally解锁，
+ * 有可能代码出现异常锁没被释放，而synchronized是由JVM来释放锁。
+ * @author 杜伟
+ *
+ */
+public class ReentrantLockDemo implements Runnable{
+	public static ReentrantLock lock = new ReentrantLock();
+	public static int i = 0;
+	@Override
+	public void run(){
+		for (int j = 0; j < 10000000; j++){
+			lock.lock();
+			try{
+				i++;
+			}
+			finally{
+				lock.unlock();
+			}
+		}
+	}
+	
+	public static void main(String[] args) throws InterruptedException{
+		ReentrantLockDemo test = new ReentrantLockDemo();
+		Thread t1 = new Thread(test);
+		Thread t2 = new Thread(test);
+		t1.start();
+		t2.start();
+		t1.join();
+		t2.join();
+		System.out.println(i);
+	}
+
+}
@@ -0,0 +1,26 @@
+package com.duwei.multythread;
+/**
+ * µ÷ÓÃThread.start&&Thread.runµÄÇø±ð£¡£¡£¡
+ * @author ¶ÅÎ°
+ */
+public class ThreadDemo {
+
+	public static void main(String[] args) {
+//		Thread thread = new Thread("t1"){
+//			@Override
+//			public void run(){
+//				System.out.println(Thread.currentThread().getName());
+//			}
+//		};
+//		thread.start();
+//----------------------------------------
+		Thread thread = new Thread("t1"){
+			@Override
+			public void run(){
+				System.out.println(Thread.currentThread().getName());
+			}
+		};
+		thread.run();
+	}
+
+}