多线程

2015-04-23

Java

原CSDN博客已弃用,文章会逐渐迁移过来。

转帖请注明本文出自weimeig的博客(http://blog.csdn.net/weimeig/article/details/79510581),请尊重他人的辛勤劳动成果,谢谢

应朋友们反馈的JAVA基础薄弱的问题,决定出一套完整的JAVA基础教程,帮助大家复习,巩固JAVA基础,今天要讲的是多线程。

创建线程的第一种方法,创建线程的类。

class Xc extends Thread{//创建线程所需要继承的类  
    public void run(){//run方法是覆盖的父类方法  
        for(int i=0;i<100;i++){  
            System.out.println("子线程");  
        }  
    }  
}  
public class XianCheng {  
    public static void main(String [] args){  
    new Xc().start();//谁调Start方法,就会去自动调用run方法  
        for(int i=0;i<100;i++){  
            System.out.println("主线程");  
        }  
    }  
}  

创建线程的第二种方法,实现线程的接口。

class Xc2 implements Runnable{  
    public void run(){  
        for(int i=0;i<100;i++){  
            System.out.println("子线程");  
        }  
    }  
}  
public class XianCheng {  
    public static void main(String [] args){  
    new Thread(new Xc2()).start();  
    for(int i=0;i<100;i++){  
            System.out.println("主线程");  
        }  
    }  
}  

创建线程的第三种方法,简约写法。

public class XianCheng {  
    public static void main(String [] args){  
    new Thread(){  
        public void run(){  
            for(int i=0;i<100;i++){  
                System.out.println("子线程");  
            }  
        }  
    }.start();  
    for(int i=0;i<100;i++){  
            System.out.println("主线程");  
        }  
    }  

}  

创建线程的第四种方法,简约写法。

public class XianCheng {      
    public static void main(String [] args){      
    new Runnable() {    
        public void run() {    
            for(int i=0;i<30;i++){      
                System.out.println("我是子线程!!!");      
            }      
        }      
    }.run();    
    for(int i=0;i<30;i++){      
            System.out.println("主线程");      
        }      
    }      
}     

观察线程的竞争

class Xc3 extends Thread{  
    public void run(){  
        System.out.println(Thread.currentThread().getName()+"线程在运行");  
    }  
}  
public class XianCheng {  
    public static void main(String [] args){  

        Xc3 xc3 = new Xc3();  
        xc3.setName("线程3");  
        xc3.start();  

        Xc3 xc31 = new Xc3();  
        xc31.setName("线程2");  
        xc31.start();  

        Xc3 xc32 = new Xc3();  
        xc32.setName("线程3");  
        xc32.start();  

            System.out.println(Thread.currentThread().getName()+"线程在运行");  

    }  
}  

线程的优先级

static int MAX_PRIORITY = 10;//线程可以具有的最高优先级(执行概率最高)
static int MIN_PRIORITY = 1; //线程可以具有的最低优先级(执行概率最低)
static int NORM_PRIORITY = 5;//分配给线程的默认优先级

写法(1)

class Xc extends Thread{  
    public void run(){  
        System.out.println("线程1在运行");  
    }  
}  
public class XianCheng {  
    public static void main(String [] args){  

        Xc xc = new Xc();//线程默认优先级是5  
        xc.setPriority(Thread.NORM_PRIORITY + 3);//数字越大优先级越高  
        xc.start();  


     new Thread(){  
        public void run(){  
            System.out.println("第二个线程正在被执行");  
        }  
      }.start();      
    }  

}  

写法(2)

public class XianCheng {  
    public static void main(String [] args){  


    new Thread(){  
         public void run(){//线程默认优先级是5  
            setPriority(Thread.NORM_PRIORITY + 3);//数字越大优先级越高  
            System.out.println("第1个线程");  
         }  
        }.start();    
     new Thread(){  
        public void run(){  
            System.out.println("第二个线程正在被执行");  
        }  
      }.start();      
    }  
}  

线程的睡眠

public class XianCheng {  
    public static void main(String [] args){  

    new Thread(){     
            public void run(){  
                for(int i=0;i<10;i++){  
                    System.out.println(Thread.currentThread().getName() + " " + i);  
                    try {  
                        Thread.sleep(1000);//1000毫秒等于一秒  
                    } catch (Exception e) {  
                        // TODO: handle exception  
                    }  
                }  
            }  
        }.start();  
    }  
}  

线程的抛异常问题,举例

都是会报错的,因为
用throws抛异常的时候,如果向主调处抛异常的方法是从父类继承的或者是从接口实现的
那么,覆盖父类的方法或实现接口方法时,如果父类中的原方法或接口中的原抽象方法
没有抛异常,则子类覆盖父类的方法或实现接口的方法也不能抛异常。

class Yy implements Runnable{  
    public void run() throws Exception  
    {  

    }  
}  
class Xx extends Thread{  
    public void run() throws Exception  
    {  

    }  
}  

当出现这种情况只能try…catch,大不了catch中什么都不写。

线程的让步

public class XianCheng {  
    public static void main(String [] args){  
        new Thread(){  
            public void run(){  
                setName("线程一:");  
                for(int i=1;i<=30;i++){  
                    System.out.println(Thread.currentThread().getName() + i);  
                }  
            }  
        }.start();  
        new Thread(){  
            public void run(){  
                setName("线程二:");  
                for(int i=1;i<=30;i++){  
                    System.out.println(Thread.currentThread().getName() + i);  
                    if(i%5==0){  
                        Thread.yield(); //线程让步出去让其他线程先执行,再次执行时,从让步的这个位置重新执行。  
                    }  
                }  
            }  
        }.start();  
    }  
}  

线程的阻塞

class Xc implements Runnable{  
    public void run(){  
        for(int i=0;i<30;i++){  
            System.out.println("子线程" + i);  
        }  
    }  
}  
public class XianCheng {  
    public static void main(String [] args){  
        Thread xc = new Thread(new Xc());  
        xc.start();  
        try {  
            xc.join();//阻塞时将当前线程暂停,直至调用join函数所对应的线程执行完毕,才继续执行程序。  
            //也就是说,当执行到这里,当前执行线程就暂停了,而去执行join所对应的xc这个线程,直到xc这个线程执行完毕才回来,此时线程们重新竞争CPU。  
        } catch (Exception e) {  
            // TODO: handle exception  
        }  
        for(int i=0;i<30;i++){  
            System.out.println("主线程" + i);  
        }  
    }  
}