您的位置:首页 > 编程语言 > Java开发

Java传统多线程的实现有两种方法,继承Thread类或者实现Runnable即可.线程启动时调用start()方法.

2015-03-06 10:25 1166 查看
实现Runnable接口相比继承Thread类有如下好处:1.避免单继承的局限,一个类可以同时实现多个接口2.适合资源的共享. 实现多线程模拟售票点卖票来说明实现Runnable即可可以达到资源共享的目的.使用继承Thread类的多线程售票实现
package org.dennist.thread.demo;/**
*
*  TicketThread.java
*
*  @version : 1.1
*
*  @author  : 苏若年    <a href="mailto:DennisIT@163.com">发送邮件</a>
*
*  @since     : 1.0        创建时间:    2013-2-24        下午02:22:49
*
*  TODO     :    class TicketThread.java is used for ...
* */public class TicketThreadT extends Thread{
private int num = 5;        //总共票数设定为5张
@Override    public void run() {        for(int i=0; i<10; i++){            if(this.num>0){        //打印买票信息
System.out.println(Thread.currentThread().getName() + "买票: " + this.num--);
}
}
}
public static void main(String[] args) {
TicketThreadT th1 = new TicketThreadT();        //线程一
th1.setName("售票口一");
TicketThreadT th2 = new TicketThreadT();        //线程二
th2.setName("售票口二");
TicketThreadT th3 = new TicketThreadT();        //线程三
th3.setName("售票口三");
//分别启动三个线程        th1.start();
th2.start();
th3.start();
}
}

程序运行结果:

总共5张票,启动了三个线程,从打印结果可以看出,一共卖出去了15张票,线程之间没有进行资源共享实现Runnable的售票线程
package org.dennist.thread.demo;/**
*
*  TicketThreadR.java
*
*  @version : 1.1
*
*  @author  : 苏若年    <a href="mailto:DennisIT@163.com">发送邮件</a>
*
*  @since     : 1.0        创建时间:    2013-2-24        下午02:29:23
*
*  TODO     :    class TicketThreadR.java is used for ...
* */public class TicketThreadR implements Runnable{
private int num = 5;            //总共票数设定为5张
@Override    public void run() {        for(int i=0; i<10; i++){            if(this.num>0){            //打印买票信息
System.out.println(Thread.currentThread().getName() + "买票: " + this.num--);
}
}
}    public static void main(String[] args) {
TicketThreadR ticketThread = new TicketThreadR();

Thread th1 = new Thread(ticketThread);    //线程一
th1.setName("售票口一");
Thread th2 = new Thread(ticketThread);    //线程二
th2.setName("售票口二");
Thread th3 = new Thread(ticketThread);    //线程三
th3.setName("售票口三");

th1.start();
th2.start();
th3.start();
}
}

程序运行结果



虽然现在程序中有三个线程,但是三个线程总共卖出了5张票,也就是说使用Runnable实现的多线程可以达到资源共享的目的.
Java多线程访问共享方式(1)如果每个线程执行的代码相同,可以使用同一个Runnable对象,这个Runnable对象中有那个共享数据,例如,买票系统就可以这么做。(2)如果每个线程执行的代码不同,这时候需要用不同的Runnable对象,有如下两种方式来实现这些Runnable对象之间的数据共享:  1、将共享数据封装在另外一个对象中,然后将这个对象逐一传递给各个Runnable对象。每个线程对共享数据的操作方法也分配到那个对象身上去完成,这样容易实现针对该数据进行的各个操作的互斥和通信。  2、将这些Runnable对象作为某一个类中的内部类,共享数据作为这个外部类中的成员变量,每个线程对共享数据的操作方法也分配给外部类,以便实现对共享数据进行的各个操作的互斥和通信,作为内部类的各个Runnable对象调用外部类的这些方法。  3、上面两种方式的组合:将共享数据封装在另外一个对象中,每个线程对共享数据的操作方法也分配到那个对象身上去完成,对象作为这个外部类中的成员变量或方法中的局部变量,每个线程的Runnable对象作为外部类中的成员内部类或局部内部类。  4、总之,要同步互斥的几段代码最好是分别放在几个独立的方法中,这些方法再放在同一个类中,这样比较容易实现它们之间的同步互斥和通信。(3)极端且简单的方式,即在任意一个类中定义一个static的变量,这将被所有线程共享。 在Thread类中存在以下的几个方法可以设置和取得名字.设置名字: public final void setName(String name) public Thread(Runnable target, String name)public Thread(String name)取得名字: public final String getName()在线程的操作中因为其操作的不确定性,所以提供了一个方法,可以取得当前的操作线程.public static Thread currentThread()说明:对于线程的名字一般是在启动前进行设置,最好不要设置相同的名字,最好不要为一个线程改名字.在Java执行中一个Java程序至少启动2个线程:一个主线程和一个垃圾回收线程. 多线程的同步问题上面的实现Runnable程序就真的没问题了吗?我们知道现实生活中买票总会有等待,跟延迟,那么我们模拟现实生活中的买票然后再来看上面的程序输出.
package org.dennist.thread.demo;/**
*
*  TicketThreadR.java
*
*  @version : 1.1
*
*  @author  : 苏若年    <a href="mailto:DennisIT@163.com">发送邮件</a>
*
*  @since     : 1.0        创建时间:    2013-2-24        下午02:29:23
*
*  TODO     :    class TicketThreadR.java is used for ...
* */public class TicketThreadR implements Runnable{
private int num = 5;            //总共票数设定为5张
@Override    public void run() {        for(int i=0; i<10; i++){            try {
Thread.sleep(200);    //休息200毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
if(this.num>0){            //打印买票信息
System.out.println(Thread.currentThread().getName() + "买票: " + this.num--);
}
}
}    public static void main(String[] args) {
TicketThreadR ticketThread = new TicketThreadR();

Thread th1 = new Thread(ticketThread);    //线程一
th1.setName("售票口一");
Thread th2 = new Thread(ticketThread);    //线程二
th2.setName("售票口二");
Thread th3 = new Thread(ticketThread);    //线程三
th3.setName("售票口三");

th1.start();
th2.start();
th3.start();
}
}


如果想解决这样的问题,就必须使用同步,所谓的同步就是指多个操作在同一个时间段内只有一个线程进行,其他线程要等待此线程完成之后才可以继续执行.可以通过同步代码的方法进行代码的加锁操作,同步的实现有2中方法:JAVA多线程同步主要依赖于若干方法和关键字
  1 wait方法  2 notify方法和notifyAll方法  3 synchronized关键字  4 atomic action(原子操作)详细说明见:[/article/4929353.html]此处针对上面情况使用同步关键字synchronized解决.同步关键字使用有2种方法  1.同步代码块  2.同步方法同步代码块使用synchronized关键字进行同步代码块的声明,但是在使用此操作时必须明确的指出到底要锁定的是哪个对象,一般是以当前对象为主.  synchronized(对象){ //一般都是讲this锁定 //锁定对象 }上面的问题使用同步代码块解决
package org.dennist.thread.demo;/**
*
*  TicketThreadR.java
*
*  @version : 1.1
*
*  @author  : 苏若年    <a href="mailto:DennisIT@163.com">发送邮件</a>
*
*  @since     : 1.0        创建时间:    2013-2-24        下午02:29:23
*
*  TODO     :    class TicketThreadR.java is used for ...
* */public class TicketThreadR implements Runnable{
private int num = 5;            //总共票数设定为5张
@Override    public void run() {        for(int i=0; i<10; i++){            //使用同步代码块
synchronized (this) {                try {
Thread.sleep(300);    //休息300毫秒
} catch (InterruptedException e) {
e.printStackTrace();
}
if(this.num>0){
//打印买票信息
System.out.println(Thread.currentThread().getName() + "买票: " + this.num--);
}
}

}
}    public static void main(String[] args) {
TicketThreadR ticketThread = new TicketThreadR();
new Thread(ticketThread,"售票口一").start();    //线程一
new Thread(ticketThread,"售票口二").start();    //线程二
new Thread(ticketThread,"售票口三").start();    //线程三    }
}

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐