多线程基础（二）

多线程基础（二）

1、创建线程

1）使用Thread创建并启动线程
– 通过继承Thread类并重写run方法来定义一个具体的线程。
run方法中定义线程要完成的任务。

package day04;
/**
 * 第一种创建线程的方法
 * 继承Thread类，重写run方法
 * run方法：定义线程要完成的任务
 * @author Administrator
 *
 */
public class ThreadDemo1 {

    public static void main(String[] args) {

        Thread t1=new MyThread1();
        Thread t2=new MyThread2();
        /**
         * start方法将线程纳入到线程调度，
         * 而不是不直接调run方法
         * 线程进入runnable状态，等待线程调度分配时间片段
         * 当线程调度将时间分配给当前线程的时候，该线程的run方法才会运行
         * 直到线程的run方法执行完毕，线程结束，
         * 最终被回收。
         * 在线程的run方法执行期间，该线程处于走走停停的状态
         */

        t1.start();
        t2.start();


    }

}
//创建MyThread1类继承Thread类
class MyThread1 extends Thread{
    //重写run方法
    public void run(){
        for(int i=0;i<1000;i++){
            System.out.println("你是谁？");
        }
    }
}
class MyThread2 extends Thread{
    public void run(){
        for(int i=0;i<1000;i++){
            System.out.println("我是查水表的");
        }
    }

}

2) 使用Runnable创建并启动线程
定义线程体Runnable
优点:
可以将线程与线程要执行的任务分离开减少耦合
同时java是单一继承，定义一个类实现Runnable接口
这样的做法可以更好的去实现其他父类或接口。
因为接口是多继承关系

package day04;
/**
 * 创建线程的第二种方法
 * 定义线程体Runnable
 * 优点:
 * 可以将线程与线程要执行的任务分离开减少耦合
 * 同时java是单一继承，定义一个类实现Runnable接口
 * 这样的做法可以更好的去实现其他父类或接口。
 * 因为接口是多继承关系
 * @author Administrator
 *
 */
public class ThreadDemo2 {

    public static void main(String[] args) {

        Runnable run1=new MyRunnable1();
        Runnable run2=new MyRunnable2();

        Thread t1=new Thread(run1);
        Thread t2=new Thread(run2);

        t1.start();
        t2.start();
    }

}
class MyRunnable1 implements Runnable{
    public void run(){
        for(int i=0;i<1000;i++){
            System.out.println("你是谁");
        }
    }
}
class MyRunnable2 implements Runnable{
    public void run(){
        for(int i=0;i<1000;i++){
            System.out.println("我是修水管的！");
        }
    }
}

3）使用内部类创建线程
当一个线程只需要一个实例时

package day04;
/**
 * 使用匿名内部类的形式实现创建线程
 * 当一个线程只需要一个实例时
 * @author Administrator
 *
 */
public class ThreadDemo3 {

    public static void main(String[] args) {
         Thread t1=new Thread(){
             public void run(){
                 for(int i=0;i<1000;i++){
                     System.out.println("你是谁呀？");
                 }
             }
         };
        t1.start();

         Thread t2=new Thread(new Runnable(){
             public void run(){
                 for(int i=0;i<1000;i++){
                     System.out.println("我是查水表的");
                 }
             }
         });
         t2.start();
         //等价于上面的写法
         //Runnable runn=new Runnable();
         //Thread t2=new Thread(runn);
    }


}

2、线程操作API

• Thread curreentThread()
  获取当前代码片段的线程

package day04;
/**
 * 获取当前代码片段的线程
 * Thread curreentThread()
 * 可以调用Thread提供的静态方法
 * @author Administrator
 *
 */

public class ThreadDemo4 {

    public static void main(String[] args) {
        //获取的就是main方法的线程 
        Thread t1=Thread.currentThread();
         System.out.println("调用main方法的线程是："+t1);

         //创建一个线程
         Thread t2=new Thread(){
             public void run(){
                //获取当前线程
                 Thread myt=Thread.currentThread();
                System.out.println("自己创建的线程是："+myt);
             }
         };
         t2.start();
         testCurrent();

    }
    public static void testCurrent(){

        Thread t=Thread.currentThread();

        System.out.println("调用testCurrent的线程是："+t);

    }

}

3、获取线程信息

Thread提供了获取线程的相关方法：

–long getId(); 返回I线程的标识符

–String getName();返回线程的名称

–int getPriority();返回线程的优先级

–Thread.state getState();获取线程的状态

–boolean isAlive();测试线程是否或者

–boolean isDaemon();测试线程是否为守护线程

–boolean isInterrupted();测试线程是否中断

package day04;
/**
 * 线程其他API
 * @author Administrator
 *
 */
public class ThreadDemo {

    public static void main(String[] args) {
        //获取main方法的线程相关信息
        Thread t=Thread.currentThread();

        //获取线程Id
        long id=t.getId();
        System.out.println("id:"+id);

        /**
         * 获取线程的名字，通常由系统指定
         * 格式为：Thread-x
         * 但调用main方法的线程名字不是这个。
         */
        String name=t.getName();
        System.out.println("name:"+name);

        //获取线程的有限级别
        int p=t.getPriority();
        System.out.println("优先级:"+p);

        //获取线程的状态
        System.out.println("状态："+t.getState());

        //获取线程是否或者
        System.out.println("alive："+t.isAlive());

        //获取线程是否是后台线程
        System.out.println("daemon:"+t.isDaemon());

        //获取线程是否被中断
        System.out.println("是否中断："+t.isInterrupted());


    }

}

4、线程优先级
线程的优先级分为10级，值为1-10,之中1最低，10最高，默认为5。

–Thread.MIN_PRIORITY 值为1

–Thread.MAX_PRIORITY 值为10

–Thread.NORMOR_PRIORITY 值为5

package day04;
/**
 * 线程优先级
 * 1-10；
 * 理论上，线程优先级高的线程，被分配的时间片段的次数多
 * @author Administrator
 *
 */
public class ThreadDemo6 {

    public static void main(String[] args) {
         Thread max=new Thread();
             for(int i=0;i<2000;i++){
                 System.out.println("max");
            }

             Thread min=new Thread();
             for(int i=0;i<2000;i++){
                 System.out.println("min");
            }

             Thread norm=new Thread();
             for(int i=0;i<2000;i++){
                 System.out.println("norm");
            }
             max.start();
             min.start();
             norm.start();
        max.setPriority(Thread.MAX_PRIORITY);
        min.setPriority(Thread.MIN_PRIORITY);
    }


}

5、守护线程

–void setDaemon(boolean)

–当参数为true时，该线程为守护线程
特点：当进程只剩下守护线程时，所有的守护线程强制终止。

6、sleep方法

–static void sleep(long ms)
该方法会使当前线程进入阻塞状态指定毫秒，当阻塞指定毫秒后，当前线程会重新进入Runnable状态，等待分配时间片。会抛出InterruptException，要捕获异常。

package day04;
/**
 * 后台线程，守护线程
 * 特点：
 * 当线程中所有的前台线程都结束时，后台线程结束，
 * 无论后台线程是否还在运行
 * 
 * sleep方法
 * 使当前线程进入一个阻塞状态
 * 线程停止运行
 * sleep(int ms)
 * sleep(1000)
 * @author Administrator
 *
 */
public class ThreadDemo7 {

    public static void main(String[] args) {
         //rose 扮演：前台线程
        Thread rose=new Thread(){
            public void run(){
                for(int i=0;i<10;i++){
                    System.out.println("rose:let me go!");
                }
                try {
                    Thread.sleep(1000);

                } catch (InterruptedException e) {

                }
                System.out.println("rose:AAAAAAAaaa");

                System.out.println("噗通");
            }
        };
        //joke 扮演者：后台线程
        Thread joke=new Thread(){
            public void run(){
                //死循环
                while(true){
                    for(int i=0;i<10;i++){
                    System.out.println("joke:you jump,i jump!");
                }
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {

                    }
            }

        }
    };
        rose.start();
        //守护线程
        joke.setDaemon(true);
        joke.start();
    }
}

7、join方法

–void join()
用于等待当前线程结束，抛出异常InterruptException

package day04;
/**
 * join可以使线程同步
 * 
 * @author Administrator
 *
 */
public class ThreadDemo9 {
    //显示图片是否下载完毕
    public static   boolean isFinish;
    public static void main(String[] args) {
        //下载线程
        Thread download =new Thread(){
            public void run(){

                for(int i=0;i<=100;i++){
                    System.out.println("down:图片下载"+i+"%");;

                }
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {

                }
                System.out.println("图片下载完成！");
                isFinish=true;
            }
        };
        /**
         * main方法中定义一个内部类show,
         * 该内部类中若想引用main方法中的其他
         * 局部变量，那么这个变量必须是final的类型
         */
        //显示线程
        Thread show=new Thread(){
            public void run(){
                try {
                    //这里应该等待下载线程将图片加载完毕之后再执行
                    download.join();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                for(int i=0;i<=100;i++){
                    System.out.println("show:图片加载"+i+"%");
                    if(!isFinish){
                        throw new  RuntimeException("图片加载失败！");
                    }
                }
                System.out.println("图片显示完成！");
            }

        };
        download.start();
        show.start();
    }

}

8、线程小实例
实现电子表的功能

package day04;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 电子表
 * @author Administrator
 *
 */
public class ThreadDemo8 {

    public static void main(String[] args) {

        SimpleDateFormat sdf=new
                 SimpleDateFormat("HH:mm:ss");

         while(true){
             Date now=new Date();
             System.out.println(sdf.format(now));

             try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {

            }
         }
    }

}