Java学习---多线程的学习

基础知识

每个正在系统上运行的程序都是一个进程（process）。每个进程包含一到多个线程(thread)。进程也可能是整个程序或者是部分程序的动态执行。

线程是一组指令的集合，或者是程序的特殊段，它可以在程序里独立执行。也可以把它理解为代码运行的上下文。所以线程基本上是轻量级的进程，它负责在单个程序里执行多任务。

Java对多线程的支持是非常强大的，他屏蔽掉了许多的技术细节，让我们可以轻松的开发多线程的应用程序。Java里面有2个方法实现多线程，

1 继承 Thread类，比如
　　class MyThread extends Thread {
　　  public void run() {
　　  // 这里写上线程的内容
　　  }
　　  public static void main(String[] args) {
　　    // 使用这个方法启动一个线程
　　    new MyThread().start();
　　  }
　　}
　　2 实现 Runnable接口，例如
　　class MyThread implements Runnable{
　　  public void run() {
　　  // 这里写上线程的内容
　　  }
　　  public static void main(String[] args) {
　　    // 使用这个方法启动一个线程
　　    new Thread(new MyThread()).start();
　　  }
　　}
一般鼓励使用第二种方法，因为Java里面只允许单一继承，但允许实现多个接口。第二个方法更加灵活。

代码示例

多线程实现1－30的累计，其中共享资源池为1－30的数字的递增，采用了同步锁synchronized。 

 1 class Sum{ //共享资源，计数器count
 2     private int count;//共享资源
 3     public int add(){
 4         synchronized(this){ //代码段1，共享锁，修饰程序段或者方法
 5             count = count + 1;
 6             System.out.println("add:" + count);
 7             return count;            
 8         }
 9     }
10 }
11 class SumThread implements Runnable{//定义线程
12     private Sum sd;
13     private int sum = 0;
14     private    int [] a = new int[10];
15     
16     public SumThread(String name, Sum sd){
17         super(name);
18         this.sd = sd;
19     }
20     public void run(){//必需的重写
21         try{
22             for(int i=0;i<10;i++){
23                 a[i] = sd.add();
24                 sum += a[i];
25                 Thread.sleep(100);
26             }
27             Thread.sleep(1000);
28         }catch(Exception e){}
29         
30         System.out.println(getName() + "累加和:" + sum);
31     }
32     public void showData(){
33         System.out.print(getName() + "获得的数为");
34         for(int i=0;i<10;i++){
35             if(i%10==0)System.out.println();
36             System.out.print(a[i] + "+\t");
37         }
38     }
39     public int getSum(){
40         return sum;
41     }
42 }
43 public class SumDemo{
44     public static void main(String [] args){
45         Sum sd = new Sum();//代表共享资源的变量
46         SumThread s1 = new SumThread("线程1",sd);//创建完毕
47         SumThread s2 = new SumThread("线程2",sd);
48         SumThread s3 = new SumThread("线程3",sd);
49         Thread st1 = new Thread(s1);
50         Thread st2 = new Thread(s2);
51         Thread st3 = new Thread(s3);
52         st1.setPriority(Thread.MAX_PRIORITY);  //代码段2
53         st2.setPriority(10);
54         st3.setPriority(1);
55          long begin = System.currentTimeMillis();
56         st1.start();//使线程运行
57         st2.start();        st3.start();
58         St1.join();  st2.join();  st3.join();
59         st1.showData();
60         st2.showData();
61         st3.showData();
62         System.out.println("总和为:" + (st1.getSum() + st2.getSum() + st3.getSum())); 
63          long end = System.currentTimeMillis(); 
64          System.out.println(“探测localhost的TCP端口，共耗时” + 
65             ( end - begin)+"毫秒");
66 }  }

View Code