Java 多线程

Java中要想实现多线程，有两种手段，一种是继续Thread类，另外一种是实现Runable接口。

1、通过实现Runnable接口线程创建
(1).定义一个类实现Runnable接口，重写接口中的run()方法。在run()方法中加入具体的任务代码或处理逻辑。
(2).创建Runnable接口实现类的对象。
(3).创建一个Thread类的对象，需要封装前面Runnable接口实现类的对象。（接口可以实现多继承）
(4).调用Thread对象的start()方法，启动线程

示例代码：

package demo.thread;

public class TreadDemo1 implements Runnable {
    private int countDown = 10;
    @Override
    // 在run方法中定义任务
    public void run() {
        while (countDown-- > 0) {
            System.out.println("#" + Thread.currentThread().getName() + "("
                    + countDown + ")");
        }
    }

    public static void main(String[] args) {
        // Runnable中run方法是一个空方法，并不会产生任何线程行为，必须显式地将一个任务附着到线程上
        TreadDemo1 tt=new TreadDemo1();
        new Thread(tt).start();
        new Thread(tt).start();
        System.out.println("火箭发射前倒计时：");
    }
}

2、通过继承Thread类创建线程
(1).首先定义一个类去继承Thread父类，重写父类中的run()方法。在run()方法中加入具体的任务代码或处理逻辑。
(2).直接创建一个ThreadDemo2类的对象，也可以利用多态性，变量声明为父类的类型。
(3).调用start方法，线程t启动，隐含的调用run()方法。
示例代码：

package demo.thread;

public class ThreadDemo2 extends Thread {
    private int countDown = 10;

    @Override
    // 在run方法中定义任务
    public void run() {
        while (countDown-- > 0) {
            System.out.println("#" + this.getName() + "(" + countDown + ")");
        }
    }

    public static void main(String[] args) {
        new ThreadDemo2().start();
        new ThreadDemo2().start();
        // 由于start方法迅速返回，所以main线程可以执行其他的操作,此时有两个独立的线程在并发运行
        System.out.println("火箭发射前倒计时：");
    }
}

3、两种方式的比较
首先分析两种方式的输出结果，同样是创建了两个线程，为什么结果不一样呢？
使用实现Runnable接口方式创建线程可以共享同一个目标对象（TreadDemo1 tt=new TreadDemo1();），实现了多个相同线程处理同一份资源。
然后再看一段来自JDK的解释：
Runnable 接口应该由那些打算通过某一线程执行其实例的类来实现。类必须定义一个称为run 的无参数方法。
设计该接口的目的是为希望在活动时执行代码的对象提供一个公共协议。例如，Thread 类实现了Runnable。激活的意思是说某个线程已启动并且尚未停止。
此外，Runnable 为非 Thread 子类的类提供了一种激活方式。通过实例化某个Thread 实例并将自身作为运行目标，就可以运行实现 Runnable 的类而无需创建 Thread 的子类。大多数情况下，如果只想重写run() 方法，而不重写其他 Thread 方法，那么应使用 Runnable 接口。这很重要，因为除非程序员打算修改或增强类的基本行为，否则不应为该类创建子类。

采用继承Thread类方式：
（1）优点：编写简单，如果需要访问当前线程，无需使用Thread.currentThread()方法，直接使用this，即可获得当前线程。
（2）缺点：因为线程类已经继承了Thread类，所以不能再继承其他的父类。
采用实现Runnable接口方式：
（1）优点：线程类只是实现了Runable接口，还可以继承其他的类。在这种方式下，可以多个线程共享同一个目标对象，所以非常适合多个相同线程来处理同一份资源的情况，从而可以将CPU代码和数据分开，形成清晰的模型，较好地体现了面向对象的思想。
（2）缺点：编程稍微复杂，如果需要访问当前线程，必须使用Thread.currentThread()方法。

所谓的后台线程，是指在程序运行的时候在后台提供一种通用服务的线程，并且这种线程并不属于程序中不可或缺的部分。因此当所有的非后台线程结束时，程序也就终止了，同时会杀死所有后台线程。反过来说，只要有任何非后台线程(用户线程)还在运行，程序就不会终止。后台线程在不执行finally子句的情况下就会终止其run方法。后台线程创建的子线程也是后台线程。
下面是一个后台线程的示例：

package demo.thread;

import java.util.concurrent.TimeUnit;

public class DaemonDemo implements Runnable {
    @Override
    public void run() {
        try {
            while (true) {
                Thread.sleep(1000);
                System.out.println("#" + Thread.currentThread().getName());
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {// 后台线程不执行finally子句
            System.out.println("finally ");
        }
    }

    public static void main(String[] args) {
        for (int i = 0; i < 10; i++) {
            Thread daemon = new Thread(new DaemonDemo());
            // 必须在start之前设置为后台线程
            daemon.setDaemon(true);
            daemon.start();
        }
        System.out.println("All daemons started");
        try {
            TimeUnit.MILLISECONDS.sleep(1000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

sleep()、join()、interrupt()示例
这是一个来自《java编程思想上的示例》

package demo.thread;

/**
 *sleep()是静态方法，是属于类的，作用是让当前线程阻塞 
 *join()是使线程同步，如在某个线程里调用t.join()表示t线程执行完再执行当前线程
 *interrupt()给线程设定一个标志表示该线程已被中断，但在异常捕获时将清理这个标志
 *所以在catch子句中，该标志为false 
 */
public class SleepJoinDemo {
    public static void main(String[] args) {
        Sleeper sleep1 = new Sleeper("sleep1", 1500);
        Sleeper sleep2 = new Sleeper("sleep2", 1500);
        Joiner join1 = new Joiner("join1", sleep1);
        Joiner join2 = new Joiner("join2", sleep1);
        sleep2.interrupt();
    }
}

class Sleeper extends Thread {
    // 可以传参设定睡眠时间
    private int sleepTime;

    public Sleeper(String name, int sleepTime) {
        super(name);
        this.sleepTime = sleepTime;
        start();// 在构造方法中启动
    }

    @Override
    public void run() {
        try {
            sleep(sleepTime);
        } catch (InterruptedException e) {
            System.out.println(getName() + " was interrupted.\n"
                    + "isInterrupted():" + isInterrupted());
            return;
        }
        System.out.println(getName() + " has awakened");
    }
}

class Joiner extends Thread {
    private Sleeper sleeper;

    public Joiner(String name, Sleeper sleeper) {
        super(name);
        this.sleeper = sleeper;
        start();
    }

    public void run() {
        try {
            sleeper.join();//合并，异步变同步
        } catch (InterruptedException e) {
            System.out.println("interrupted");
        }
        System.out.println(getName() + " join completed");
    }
}

转自java多线程总结三：sleep()、join()、interrupt()示例 - Touch_2011的专栏 - 博客频道 - CSDN.NET

MXOXW

Life always finds a way.

Java 多线程

评论