java笔记五：多线程的使用

　　以前学习基础的时候学习了一段时间的多线程，上课的时候老师也讲过一遍，那时候感觉学的似懂非懂。因为到现在很长一段时间没有用到多线程的知识，所以现在基本上忘了差不多了。但是下个星期要面试了，所以今天特意又研究了一下多线程，免得被问到多线程问题时什么都不记得了那就麻烦了。现在对java比较熟悉了，所以再一次学习多线程知识，感觉没有那么难了（记得刚接触多线程的时候，感觉非常吃力）。

　　首先讲一下进程和线程的区别：

　　　　进程：每个进程都有独立的代码和数据空间（进程上下文），进程间的切换会有较大的开销，一个进程包含1--n个线程。

　　　　线程：同一类线程共享代码和数据空间，每个线程有独立的运行栈和程序计数器(PC)，线程切换开销小。

　　　　线程和进程一样分为五个阶段：创建、就绪、运行、阻塞、终止。

　　　　多进程是指操作系统能同时运行多个任务（程序）。

　　　　多线程是指在同一程序中有多个顺序流在执行。

　　在java中创建一个线程有两种方法：

　　　　①实现java.lang.Runnable接口，重写run()方法，启动：new Thread(this).start()。

package com.thread;

public class ThreadTest1 {
    public static void main(String[] args) {
        Runnable1 r = new Runnable1();
        //r.run();并不是线程开启，而是简单的方法调用
        Thread t = new Thread(r);//创建线程
        //t.run(); //如果该线程是使用独立的 Runnable 运行对象构造的，则调用该 Runnable 对象的 run 方法；否则，该方法不执行任何操作并返回。
        t.start(); //线程开启
        for (int i = 0; i < 100; i++) {
            System.out.println("main:"+i);
        }
    }
}
class Runnable1 implements Runnable{
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println("Thread-----:"+i);
        }
    }
}

　　要注意的是：

　　　　1.r.run()并不是启动线程，而是简单的方法调用。

　　　　2.Thread也有run()方法，如果该线程是使用独立的 Runnable 运行对象构造的，则调用该 Runnable 对象的 run 方法；否则，该方法不执行任何操作并返回。

　　　　3.并不是一启动线程（调用start()方法）就执行这个线程，而是进入就绪状态，什么时候运行要看CUP。

　　　　②继承java.lang.Thread类，重写run()方法。

package com.thread;

public class TestThread2 {
    public static void main(String[] args) {
        Thread1 t = new Thread1();
        //t.run(); //这里也不能直接调用方法
        t.start();
        for (int i = 0; i < 100; i++) {
            System.out.println("main:"+i);
        }
    }
}

//尽量使用实现Runnnable接口，因为接口比较灵活
class Thread1 extends Thread{
    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println("Thread-----:"+i);
        }
    }
}

虽然两种方法都可行，但是最好还是用第一种方法，因为使用接口灵活性好，java中时单继承、多实现。

Thread类中常用的方法有：

　　①sleep(long millis): 在指定的毫秒数内让当前正在执行的线程休眠（暂停执行）。

package com.thread;
import java.util.Date;
/**
 * sleep()指在指定的毫秒数内让当前正在执行的线程休眠（暂停执行）。
 * @author Administrator
 *
 */
public class SleepTest {
    public static void main(String[] args) {
        Thread2 t = new Thread2();
        t.start();
        try {
            Thread.sleep(10000); //主线程睡眠10秒钟
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //主线程睡眠10秒钟后结束t线程
        //t.interrupt(); //这种结束方式比较粗暴，如果t线程打开了某个资源还没来得及关闭也就是run方法还没有执行完就强制结束线程，会导致资源无法关闭
        //t.stop();也是结束某个线程，这种方式比interrupt()更粗暴
        t.flag = false;
    }
}
class Thread2 extends Thread{
    boolean flag = true; //用这种方式结束线程很不错，用一个变量控制run方法什么时候不再执行，不会出现run方法没有执行完毕就结束
    @Override
    public void run() { //run方法一结束，整个线程就终止了
        while(flag){
            System.out.println("---"+new Date()+"---");
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                return;
            }
        }
    }
}

　　②join():指等待t线程终止。也可以理解为将t线程合并到当前线程来，等待t线程结束后再往下执行。相当于方法调用

package com.thread;

import java.util.Date;

/*
 * t.join()方法指等待t线程终止。也可以理解为将t线程合并到当前线程来，等待t线程结束后再往下执行。相当于方法调用
 */
public class TestJoin {
    public static void main(String[] args) {
        Thread t = new Thread3("abc");
        t.start();
        for (int i = 0; i < 20; i++) {
            System.out.println("我是main线程");
            if(i==10){
                try {
                    t.join();
                } catch (InterruptedException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }
            }
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
class Thread3 extends Thread{
    public Thread3(String s) { //给该线程取一个名字，用getName()方法可以去到该名字
        super(s);
    }
    @Override
    public void run() {
        for (int i = 0; i < 20; i++) {
            System.out.println("我是"+getName()+"线程");
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

运行该程序结果为：

我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是main线程
我是abc线程
我是abc线程
我是abc线程
我是abc线程
我是abc线程
我是abc线程
我是abc线程
我是abc线程
我是abc线程
我是abc线程
我是main线程
我是main线程
我是main线程
我是main线程
我是main线程
我是main线程
我是main线程
我是main线程
我是main线程

可以看到从第22行起就开始顺序执行了，因为i=10的时候就将该形成合并了。

　　③yield():暂停当前正在执行的线程对象，并执行其他线程。

　　④setPriority(): 更改线程的优先级。

　　　　MIN_PRIORITY = 1
  　　   NORM_PRIORITY = 5
           MAX_PRIORITY = 10

package com.thread;


/*t.yield()暂停当前正在执行的线程对象，并执行其他线程。
 * 
 * MIN_PRIORITY 1
 * NORM_PRIORITY 5
 * MAX_PRIORITY 10
 */
public class TestYield {
    public static void main(String[] args) {
        Thread4 t1 = new Thread4("t1");
        Thread4 t2 = new Thread4("t2");
        t1.setPriority(Thread.MAX_PRIORITY);
        t2.setPriority(Thread.MIN_PRIORITY);
        System.out.println(t1.getPriority());
        System.out.println(t2.getPriority());
        t1.start();
        t2.start();
        
    }
}
class Thread4 extends Thread{
    public Thread4(String s) { 
        super(s);
    }
    @Override
    public void run() {
        for (int i = 0; i < 1000; i++) {
            System.out.println("我是"+getName()+"线程"+i);
            if(i%10 == 0){
                yield();
            }
        }
    }
}

由于运行结果太长就没有贴上来了，运行该程序，可以看到t1和t2两个进程每次当i为10的倍数时都会让给其他线程执行。

　　⑤interrupt():中断某个线程，这种结束方式比较粗暴，如果t线程打开了某个资源还没来得及关闭也就是run方法还没有执行完就强制结束线程，会导致资源无法关闭

　　要想结束进程最好的办法就是用sleep()函数的例子程序里那样，在线程类里面用以个boolean型变量来控制run()方法什么时候结束，run()方法一结束，该线程也就结束了。

　　⑥还有很多的方法就不一一列举了.........

　　

　　当然，多线程难点不在这些，多线程的难点在于多线程之间的协调。关于多线程的协调待续........