Java多线程分析案例

1．public class MyThread extends Thread {   
2．  public void run() {   
3．   System.out.println("MyThread.run()");   
4．  }   
5．}  
 
6．MyThread myThread1 = new MyThread();   
7．MyThread myThread2 = new MyThread();   
8．myThread1.start();   
9．myThread2.start();

1．public class MyThread implements Runnable {   
2．  public void run() {   
3．   System.out.println("MyThread.run()");   
4．  }   
5．} 
6．MyThread myThread = new MyThread();   
7．Thread thread = new Thread(myThread);   
8．thread.start(); 

1．import java.util.concurrent.*;   
2．import java.util.Date;   
3．import java.util.List;   
4．import java.util.ArrayList;   
5．   
6．/**  
7．* 有返回值的线程  
8．*/   
9．@SuppressWarnings("unchecked")   
10．public class Test {   
11．public static void main(String[] args) throws ExecutionException,   
12．    InterruptedException {   
13．   System.out.println("----程序开始运行----");   
14．   Date date1 = new Date();   
15．   
16．   int taskSize = 5;   
17．   // 创建一个线程池   
18．   ExecutorService pool = Executors.newFixedThreadPool(taskSize);   
19．   // 创建多个有返回值的任务   
20．   List<Future> list = new ArrayList<Future>();   
21．   for (int i = 0; i < taskSize; i++) {   
22．    Callable c = new MyCallable(i + " ");   
23．    // 执行任务并获取 Future 对象   
24．    Future f = pool.submit(c);   
25．    // System.out.println(">>>" + f.get().toString());   
26．    list.add(f);   
27．   }   
28．   // 关闭线程池   
29．   pool.shutdown();   
30．   
31．   // 获取所有并发任务的运行结果   
32．   for (Future f : list) {   
33．    // 从 Future 对象上获取任务的返回值，并输出到控制台   
34．    System.out.println(">>>" + f.get().toString());   
35．   }   
36．   
37．   Date date2 = new Date();   
38．   System.out.println("----程序结束运行----，程序运行时间【"   
39．     + (date2.getTime() - date1.getTime()) + "毫秒】");   
40．}   
41．}   
42．   
43．class MyCallable implements Callable<Object> {   
44．private String taskNum;   
45．   
46．MyCallable(String taskNum) {   
47．   this.taskNum = taskNum;   
48．}   
49．   
50．public Object call() throws Exception {   
51．   System.out.println(">>>" + taskNum + "任务启动");   
52．   Date dateTmp1 = new Date();   
53．   Thread.sleep(1000);   
54．   Date dateTmp2 = new Date();   
55．   long time = dateTmp2.getTime() - dateTmp1.getTime();   
56．   System.out.println(">>>" + taskNum + "任务终止");   
57．   return taskNum + "任务返回运行结果,当前任务时间【" + time + "毫秒】";   58．}   
59．} 

1. public class Counter { 
2.  private volatile int count = 0; 
3.  public void inc(){ 
4.   try { 
5.    Thread.sleep(3); 
6.   } catch (InterruptedException e) { 
7.    e.printStackTrace(); 
8.   } 
9.   count++; 
10.  } 
11.  @Override 
12.  public String toString() { 
13.   return "[count=" + count + "]"; 
14.  } 
15. }  
16. //---------------------------------华丽的分割线----------------------------- 
17. public class VolatileTest { 
18.  public static void main(String[] args) { 
19.   final Counter counter = new Counter(); 
20.   for(int i=0;i<1000;i++){ 
21.    new Thread(new Runnable() { 
22.     @Override 
23.     public void run() { 
24.      counter.inc(); 
25.     } 
26.    }).start(); 
27.   } 
28.   System.out.println(counter); 
29.  } 
30. } 

1. ExecutorService newCachedThreadPool = Executors.newCachedThreadPool(); 
2. ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(4); 
3. ScheduledExecutorService newScheduledThreadPool = Executors.newScheduledThreadPool(4); 
4. ExecutorService newSingleThreadExecutor = Executors.newSingleThreadExecutor(); 

26.  /* 
27.          * Proceed in 3 steps: 
28.          * 
29.          * 1. If fewer than corePoolSize threads are running, try to 
30.          * start a new thread with the given command as its first 
31.          * task.  The call to addWorker atomically checks runState and 
32.          * workerCount, and so prevents false alarms that would add 
33.          * threads when it shouldn‘t, by returning false. 
34.          * 
35.          * 2. If a task can be successfully queued, then we still need 
36.          * to double-check whether we should have added a thread 
37.          * (because existing ones died since last checking) or that 
38.          * the pool shut down since entry into this method. So we 
39.          * recheck state and if necessary roll back the enqueuing if 
40.          * stopped, or start a new thread if there are none. 
41.          * 
42.          * 3. If we cannot queue task, then we try to add a new 
43.          * thread.  If it fails, we know we are shut down or saturated 
44.          * and so reject the task. 
45.          */ 

1. package com.example; 
2. /** 
3.  * 三个线程 a、b、c 并发运行，b,c 需要 a 线程的数据怎么实现（上海 3 期学员提供） 4.  * 
5.  */ 
6. public class ThreadCommunication { 
7.  private static int num;//定义一个变量作为数据 
8.   
9.  public static void main(String[] args) { 
10.    
11.   Thread threadA = new Thread(new Runnable() { 
12.     
13.    @Override 
14.    public void run() { 
15.     try { 
16.      //模拟耗时操作之后初始化变量 num 
17.      Thread.sleep(1000); 
18.      num = 1; 
19.       
20.     } catch (InterruptedException e) { 
21.      e.printStackTrace(); 
22.     } 
23.    } 
24.   }); 
25.   Thread threadB = new Thread(new Runnable() { 
26.     
27.    @Override 
28.    public void run() { 
29.     System.out.println(Thread.currentThread().getName()+"获取到 num 的值为："+num); 
30.    } 
31.   }); 
32.   Thread threadC = new Thread(new Runnable() { 
33.     
34.    @Override 
35.    public void run() { 
36.     System.out.println(Thread.currentThread().getName()+"获取到 num 的值为："+num); 
37.    } 
38.   }); 
39.   //同时开启 3 个线程 
40.   threadA.start(); 
41.   threadB.start(); 
42.   threadC.start(); 
43.    
44.  } 
45. } 
46.

1. public class ThreadCommunication { 
2.  private static int num; 
3.  /** 
4.   * 定义一个信号量，该类内部维持了多个线程锁，可以阻塞多个线程，释放多个线程， 
5. 线程的阻塞和释放是通过 permit 概念来实现的 
6.   * 线程通过 semaphore.acquire()方法获取 permit，如果当前 semaphore 有 permit 则分配给该线程， 
7. 如果没有则阻塞该线程直到 semaphore 
8.   * 调用 release（）方法释放 permit。 
9.   * 构造函数中参数：permit（允许） 个数， 
10.   */ 
11.  private static Semaphore semaphore = new Semaphore(0); 
12.  public static void main(String[] args) { 
13.    
14.   Thread threadA = new Thread(new Runnable() { 
15.     
16.    @Override 
17.    public void run() { 
18.     try { 
19.      //模拟耗时操作之后初始化变量 num 
20.      Thread.sleep(1000); 
21.      num = 1; 
22.      //初始化完参数后释放两个 permit 
23.      semaphore.release(2); 
24.       
25.     } catch (InterruptedException e) { 
26.      e.printStackTrace(); 
27.     } 
28.    } 
29.   }); 
30.   Thread threadB = new Thread(new Runnable() { 
31.     
32.    @Override 
33.    public void run() { 
34.     try { 
35.      //获取 permit，如果 semaphore 没有可用的 permit 则等待，如果有则消耗一个 
36.      semaphore.acquire(); 
37.     } catch (InterruptedException e) { 
38.      e.printStackTrace(); 
39.     } 
40.     System.out.println(Thread.currentThread().getName()+"获取到 num 的值为："+num); 
41.    } 
42.   }); 
43.   Thread threadC = new Thread(new Runnable() { 
44.     
45.    @Override 
46.    public void run() { 
47.     try { 
48.      //获取 permit，如果 semaphore 没有可用的 permit 则等待，如果有则消耗一个 
49.      semaphore.acquire(); 
50.     } catch (InterruptedException e) { 
51.      e.printStackTrace(); 
52.     } 
53.     System.out.println(Thread.currentThread().getName()+"获取到 num 的值为："+num); 
54.    } 
55.   }); 
56.   //同时开启 3 个线程 
57.   threadA.start(); 
58.   threadB.start(); 
59.   threadC.start(); 
60.    
61.  } 
62. }

1．package .com; 
2．/** 
3．* 一个简单的死锁类 
4．* 当 DeadLock 类的对象 flag==1 时（td1），先锁定 o1,睡眠 500 毫秒 
5．* 而 td1 在睡眠的时候另一个 flag==0 的对象（td2）线程启动，先锁定 o2,睡眠 500 毫秒   
6．* td1 睡眠结束后需要锁定 o2 才能继续执行，而此时 o2 已被 td2 锁定；   
7．* td2 睡眠结束后需要锁定 o1 才能继续执行，而此时 o1 已被 td1 锁定；   
8．* td1、td2 相互等待，都需要得到对方锁定的资源才能继续执行，从而死锁。   
9．*/     
10．public class DeadLock implements Runnable {     
11．    public int flag = 1;     
12．    //静态对象是类的所有对象共享的     
13．    private static Object o1 = new Object(), o2 = new Object();     
14．    public void run() {     
15．        System.out.println("flag=" + flag);     
16．        if (flag == 1) {     
17．            synchronized (o1) {     
18．                try {     
19．                    Thread.sleep(500);     
20．                } catch (Exception e) {     
21．                    e.printStackTrace();     
22．                }     
23．                synchronized (o2) {     
24．                    System.out.println("1");     
25．                }     
26．            }     
27．        }     
28．        if (flag == 0) {     
29．            synchronized (o2) {     
30．                try {     
31．                    Thread.sleep(500);     
32．                } catch (Exception e) {     
33．                    e.printStackTrace();     
34．                }     
35．                synchronized (o1) {     
36．                    System.out.println("0");     
37．                }     
38．            }     
39．        }     
40．    }       
41．    public static void main(String[] args) {        
42．        DeadLock td1 = new DeadLock();     
43．        DeadLock td2 = new DeadLock();     
44．        td1.flag = 1;     
45．        td2.flag = 0;     
46．        //td1,td2 都处于可执行状态，但 JVM 线程调度先执行哪个线程是不确定的。     47．        //td2 的 run()可能在 td1 的 run()之前运行     
48．        new Thread(td1).start();     
49．        new Thread(td2).start();     
50．    }     
51．} 

1．package igeekhome.com; 
2．public class MySignal{ 
3． //共享的变量 
4． private boolean hasDataToProcess=false;  
5．  //取值 
6． public boolean getHasDataToProcess() { 
7．  return hasDataToProcess; 
8． } 
9．  //存值 
10． public void setHasDataToProcess(boolean hasDataToProcess) { 
11．  this.hasDataToProcess = hasDataToProcess; 
12． } 
13． public static void main(String[] args){ 
14．     //同一个对象 
15．  final MySignal my=new MySignal();  
16．     //线程 1 设置 hasDataToProcess 值为 true 
17．  final Thread t1=new Thread(new Runnable(){ 
18．   public void run() { 
19．    my.setHasDataToProcess(true); 
20．   }    
21．  });   
22．  t1.start();  
23．    //线程 2 取这个值 hasDataToProcess 
24．  Thread t2=new Thread(new Runnable(){ 
25．   public void run() { 
26．    try { 
27．                  //等待线程 1 完成然后取值 
28．     t1.join(); 
29．    } catch (InterruptedException e) { 
30．     e.printStackTrace(); 
31．    } 
32．    my.getHasDataToProcess(); 
33．    System.out.println("t1 改变以后的值：" + my.isHasDataToProcess()); 34．   }   
35．  });  
36．  t2.start(); 
37．} 
38．} 
结果： 
 
 t1 改变以后的值：true

1．package igeekhome.com; 
2．//资源类 
3． class Resource{ 
4．    private String name;   
5．    private int count=1;   
6．    private boolean flag=false;   
7．    public synchronized void set(String name){   
8．     //生产资源 
9．        while(flag) { 
10．            try{ 
11．             //线程等待。消费者消费资源 
12．             wait(); 
13．             }catch(Exception e){}   
14．        } 
15．        this.name=name+"---"+count++;   
16．        System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);   
17．        flag=true;   
18．        //唤醒等待中的消费者 
19．        this.notifyAll(); 
20．        }   
21．    public synchronized void out(){  
22．     //消费资源 
23．        while(!flag) { 
24．         //线程等待，生产者生产资源 
25．            try{wait();}catch(Exception e){}   
26．        } 
27．        System.out.println(Thread.currentThread().getName()+"...消费者..."+this.name);   
28．        flag=false;   
29．        //唤醒生产者，生产资源 
30．        this.notifyAll();  
31．        }   
32．}   
33． //生产者 
34． class Producer implements Runnable{   
35．     private Resource res;   
36．     Producer(Resource res){   
37．         this.res=res;   
38．     }   
39．     //生产者生产资源 
40．     public void run(){   
41．         while(true){   
42．             res.set("商品");  
43．         }   
44．     }   
45． }   
46． //消费者消费资源 
47． class Consumer implements Runnable{   
48．     private Resource res;   
49．     Consumer(Resource res){   
50．         this.res=res;   
51．     }   
52．     public void run(){   
53．         while(true){   
54．             res.out();   
55．         }   
56．     }   
57． }   
58．public class ProducerConsumerDemo{   
59．    public static void main(String[] args){   
60．        Resource r=new Resource();   
61．        Producer pro=new Producer(r);   
62．        Consumer con=new Consumer(r);   
63．        Thread t1=new Thread(pro);   
64．        Thread t2=new Thread(con);   
65．        t1.start();   
66．        t2.start();   
67．    }   
68．} 

wait()：使一个线程处于等待（阻塞）状态，并且释放所持有的对象的锁； 
sleep()：使一个正在运行的线程处于睡眠状态，是一个静态方法，调用此方法要处理InterruptedException异常； 
notify()：唤醒一个处于等待状态的线程，当然在调用此方法的时候，并不能确切的唤醒某一个等待状态的线程，
而是由JVM确定唤醒哪个线程，而且与优先级无关； 
notityAll()：唤醒所有处于等待状态的线程，该方法并不是将对象的锁给所有线程，而是让它们竞争，只有获得锁
的线程才能进入就绪状态； 
注意：java 5 通过Lock接口提供了显示的锁机制，Lock接口中定义了加锁（lock（）方法）和解锁（unLock（）
方法），增强了多线程编程的灵活性及对线程的协调