/*************************************************************************************/ 此部落格主要是在觀看張孝祥老師的教學視訊的過程中，自己所做的學習筆記，在此以部落格的形式分享出來，方便大家學習，建議大家觀看視訊，以此筆記作為回顧資料。 參考資料 傳智播客_張孝祥_Java多執行緒與併發庫高階應用視訊教程下載 視訊下載 /*******************01張孝祥傳統執行緒技術回顧************************/ 建立執行緒的兩種方式： 1,建立Thread的子類，重寫run方法 2,給Thread類傳入Runnable介面 兩種方式的區別： 第二種方式可以實現資料共享，而且更傾向於面向物件的程式設計思想。一般都是採用第二種方式。 new Thread().start(); 呼叫了start方法後，就會執行Thread類的run方法,如下 public void run(){     if(target!=null){        targe.run();     } } 如果target為空，就什麼也不做 new Thread(         new Runnable(){              public void run() { //1 }         }   ){        public void run() { //2 }  }.start(); 執行的是2run方法 執行的步驟： 先執行子類的run方法，如果子類沒有重寫run方法，就去執行父類的run方法，上述程式碼中子類重寫了run方法，所以就不會執行Runnable中的run方法。 /*******************02張孝祥傳統定時器技術回顧************************/
 1秒後，炸一次  new Timer().schedule(new TimerTask() {        @Override        public void run() {             System.out.println("bombing!"); }   }, 1000); 每隔兩秒炸一次<一方式>
new Timer().schedule(new TimerTask() {        @Override        public void run() {             System.out.println("bombing!"); } }, 1000，2000);  每隔兩秒鐘炸一次 <二方式>  new Timer().schedule(new MyTimerTask(), 2000);  class MyTimerTask extends TimerTask{    @Override    public void run() {         System.out.println("bombing!");         new Timer().schedule(new MyTimerTask(),2000);      }   } 注意：每個TimerTask()只能執行一次 先隔一秒炸一次，再隔兩秒鐘炸一次，再擱一秒鐘炸一次，。。。。 private static int count =0; new Timer().schedule(new MyTimerTask(), 1000); class MyTimerTask extends TimerTask{    @Override    public void run() {          count = (count+1)%2;         System.out.println("bombing!");         new Timer().schedule(new TimerTask(),1000+count*1000);      } } /*******************03張孝祥傳統執行緒互斥技術************************/
在靜態方法中，不能new內部類的例項物件 原因： 內部類，可以訪問外部類的成員變數，呼叫靜態方法的時候，沒有建立物件，此時沒有可以訪問的成員變數，所以會報錯。 回顧需要重新看視訊 
/*******************04張孝祥傳統執行緒同步通訊技術************************/
回顧需要重新看視訊 /*******************05張孝祥執行緒範圍內變數的概念************************/
執行緒內部共享資料，執行緒間資料獨立 package cn.itcast.heima2; import java.util.HashMap; import java.util.Map; import java.util.Random; public class ThreadScopeShareData {  private static Map<Thread, Integer> threadData = new HashMap<Thread, Integer>();  public static void main(String[] args) {       for(int i=0;i<2;i++){            new Thread(new Runnable(){            @Override             public void run() {                  int data = new Random().nextInt();                  System.out.println(Thread.currentThread().getName() + " has put data :" + data);                   threadData.put(Thread.currentThread(), data);                  new A().get();                  new B().get();             }        }).start();    }  }   static class A{       public void get(){            int data = threadData.get(Thread.currentThread());            System.out.println("A from " + Thread.currentThread().getName() + " get data :" + data);       }  }  static class B{       public void get(){       int data = threadData.get(Thread.currentThread());       System.out.println("B from " + Thread.currentThread().getName()+ " get data :" + data);     }  } } /*******************06張孝祥ThreadLocal類及其應用技巧************************/
ThreadLocal類，實現了執行緒內部共享資料，執行緒間資料獨立，比05節視訊中的更加簡化方便

《1》 import java.util.HashMap; import java.util.Map; import java.util.Random; public class ThreadLocalTest {      public static void main(String[] args) {           new ThreadLocalTest().init();      }    //init      private void init(){           for(int i =0;i<2;i++){                new Thread(new Runnable() {                     public void run() {                          int data = new Random().nextInt();                          Person.getThreadInstance().setName(Thread.currentThread().getName());                           Person.getThreadInstance().setAge(data);                          new A().get();                           new B().get();                 }             }).start();         }     }   //A  class A {       Person person = Person.getThreadInstance();       public void get(){            System.out.println("A：-"+Thread.currentThread().getName()+":name:"+person.getName()+":age:"+person.getAge());          }  }  //B  class B {       Person person = Person.getThreadInstance();       public void get(){            System.out.println("B：-"+Thread.currentThread().getName()+":name:"+person.getName()+":age:"+person.getAge());       } }  //Person   將跟執行緒相關的繫結，放在共享的資料類的內部實現      static class Person{           private static ThreadLocal<Person>  threadLocal = new ThreadLocal<ThreadLocalTest.Person>();            private Person(){           }          public static Person  getThreadInstance(){                Person person = threadLocal.get();                if(person==null){                     person = new Person();                     threadLocal.set(person);                }                return person;.          }           private String name;           private int age;           public String getName() {                return name;           }           public void setName(String name) {                 this.name = name;           }           public int getAge() {                return age;           }           public void setAge(int age) {                this.age = age;           }     }  }
《2》
import java.util.HashMap; import java.util.Map; import java.util.Random; public class ThreadLocalTest {      public static final ThreadLocal<Person>  threadlocal = new  ThreadLocal(){               @Override               protected Object initialValue() {                    return new Person();               }     };      public static void main(String[] args) {           new ThreadLocalTest().init();      }      private void init(){           for(int i =0;i<2;i++){                new Thread(new Runnable() {                     public void run() {                          int data = new Random().nextInt();                          threadlocal.get().setName(Thread.currentThread().getName());                          threadlocal.get().setAge(data);                          new A().get();                          new B().get();                 }            }).start();         }     }      //A      class A {           Person person = threadlocal.get();           public void get(){                System.out.println("A：-"+Thread.currentThread().getName()+":name:"+person.getName()+":age:"+person.getAge());              }      }    //B     class B {        Person person = threadlocal.get();        public void get(){            System.out.println("B：-"+Thread.currentThread().getName()+":name:"+person.getName()+":age:"+person.getAge());         }     }       //Person        static class Person{           public Person(){            }           private String name;            private int age;           public String getName() {                return name;           }           public void setName(String name) {                 this.name = name;           }           public int getAge() {                return age;           }           public void setAge(int age) {                this.age = age;           }     } } /************07張孝祥多個執行緒之間共享資料的方式的討論**************/
如果每個執行緒執行的程式碼相同，可以使用同一個Runnable物件，這個Runnable物件中有那個共享資料，例如，買票系統就可以這麼做。 如果每個執行緒執行的程式碼不同，這時候需要用不同的Runnable物件，有如下兩種方式來實現這些Runnable物件之間的資料共享： 第一種： 將共享資料封裝在另外一個物件中，然後將這個物件逐一傳遞給各個Runnable物件。每個執行緒對共享資料的操作方法也分配到那個物件身上去完成，這樣容易實現針對該資料進行的各個操作的互斥和通訊。  第二種：將這些Runnable物件作為某一個類中的內部類，共享資料作為這個外部類中的成員變數，每個執行緒對共享資料的操作方法也分配給外部類，以便實現對共享資料進行的各個操作的互斥和通訊，作為內部類的各個Runnable物件呼叫外部類的這些方法。 上面兩種方式的組合：將共享資料封裝在另外一個物件中，每個執行緒對共享資料的操作方法也分配到那個物件身上去完成，物件作為這個外部類中的成員變數或方法中的區域性變數，每個執行緒Runnable物件作為外部類中的成員內部類或區域性內部類。 總之，要同步互斥的幾段程式碼最好是分別放在幾個獨立的方法中，這些方法再放在同一個類中，這樣比較容易實現它們之間的同步互斥和通訊。  極端且簡單的方式，即在任意一個類中定義一個static的變數，這將被所有執行緒共享。 設計四個執行緒，其中兩個執行緒每次對j加一，另外兩個執行緒每次對j減一
第一種示例程式碼 public class MultiThreadShareData {    private static ShareData shareData = new ShareData();   public static void main(String[] args) {       MyRunnable1 runNable1 = new MyRunnable1(shareData);       MyRunnable2 runNable2 = new MyRunnable2(shareData);       new Thread(runNable1).start();       new Thread(runNable2).start();   } }  class ShareData{      private int j =0;  public ShareData(){  }       public void increment(){           j++;      }      public void decrement(){           j--;      } } class MyRunnable1 implements Runnable{      private ShareData shareData;      public MyRunnable1(ShareData shareData){           this.shareData = shareData;      }      public void run() {           this.shareData.increment();      } }  class MyRunnable2 implements Runnable{     private ShareData shareData;     public MyRunnable2(ShareData shareData){           this.shareData = shareData;      }     public void run() {           this.shareData.decrement();      } }  或者 public class MultiThreadShareData {    public static void main(String[] args) {       MultiThreadShareData multiThreadShareData = new MultiThreadShareData(); ShareData shareData = multiThreadShareData.new ShareData();        MyRunnable1 runNable1 = multiThreadShareData.new MyRunnable1(shareData);       MyRunnable2 runNable2 = multiThreadShareData.new MyRunnable2(shareData);       new Thread(runNable1).start();       new Thread(runNable2).start();   } class ShareData{      private int j =0;  public ShareData(){  }       public void increment(){           j++;      }      public void decrement(){           j--;      } } class MyRunnable1 implements Runnable{      private ShareData shareData;      public MyRunnable1(ShareData shareData){           this.shareData = shareData;      }      public void run() {           this.shareData.increment();      } }  class MyRunnable2 implements Runnable{     private ShareData shareData;     public MyRunnable2(ShareData shareData){           this.shareData = shareData;      }     public void run() {           this.shareData.decrement();      } }  }  第二種示例程式碼 public class MultiThreadShareData { public static void main(String[] args) {  final ShareData shareData = new ShareData();          new Thread(new Runnable() {  public void run() {                      shareData.increment();              }         }).start();         new Thread(new Runnable() { public void run() {                   shareData.decrement();