java创建启动多线程的三种方式

java创建启动多线程的三种方式

标签：
java多线程thread

2013-10-24 11:08
1503人阅读 评论(0)
收藏
举报

本文章已收录于：


分类：
java（20）




作者同类文章X

版权声明：本文为博主原创文章，未经博主允许不得转载。

线程的创建和启动 

  java使用Thread代表线程，所有的对象都是Thread类或其之类的实例

使用继承Tread类来启动多线程的基本步骤:

  1.创建Thread类的子类，并重写run()方法，该方法代表了该线程完成的任务。run方法为线程执行体。

  2.创建Thread类子类的实例，即创建了线程的对象。

  3.调用线程的start()方法来启动线程。

欢迎加入QQ交流3群：317874559

[java]
view plain
copy
print?





package com.java.xiong.Tread16;  
  
  
public class ss extends Thread {  
      
    //重新run方法  
        @Override  
        public void run() {  
              
            for(int i=0;i<100;i++){  
                //当前线程  
                System.out.println("线程名"+i+":"+this.getName());  
            }  
        }  
        //启动主线程main  
    public static void main(String []arg){  
        for(int i=0;i<100;i++){  
            //当前线程  
            System.out.println(Thread.currentThread().getName());  
            if(i==10)  
            {  
                //启动第一个线程  
                new ss().start();  
                //启动第二个线程  
                new ss().start();  
            }  
        }  
    }  
  
}  

package com.java.xiong.Tread16;

public class ss extends Thread {

//重新run方法
@Override
public void run() {

for(int i=0;i<100;i++){
//当前线程
System.out.println("线程名"+i+":"+this.getName());
}
}
//启动主线程main
public static void main(String []arg){
for(int i=0;i<100;i++){
//当前线程
System.out.println(Thread.currentThread().getName());
if(i==10)
{
//启动第一个线程
new ss().start();
//启动第二个线程
new ss().start();
}
}
}

}

使用Runnable接口来创建并启动线程的步骤
   1.定义Runnable接口的实现类，并重写该接口的run()方法；run()方法则为该线程的执行体

    2.创建Runnable接口实现类的实例

    3.实例化Thread类，参数为Runnable接口实现类的对象(Thread类的对象才是正在的线程对象)来启动线程

[java]
view plain
copy
print?





package com.java.xiong.Tread16;  
  
//创建线程对象  
public class RunnableTread implements Runnable {  
  
    @Override  
    public void run() {  
  
        for (int i = 0; i < 100; i++) {  
            // 当前线程  
            System.out.println("线程名" + i + ":"  
                    + Thread.currentThread().getName());  
        }  
  
    }  
  
}  

package com.java.xiong.Tread16;

//创建线程对象
public class RunnableTread implements Runnable {

@Override
public void run() {

for (int i = 0; i < 100; i++) {
// 当前线程
System.out.println("线程名" + i + ":"
+ Thread.currentThread().getName());
}

}

}

[java]
view plain
copy
print?





package com.java.xiong.Tread16;  
  
public class RunnableTest {  
  
    public static void main() {  
          
        RunnableTread runs=new RunnableTread();  
        //获取线程对象  
        Thread tr=new Thread(runs);  
        for (int i = 0; i < 100; i++) {  
            // 当前线程  
            System.out.println(Thread.currentThread().getName());  
            if (i == 10) {  
                // 启动第一个线程  
                tr.start();  
                // 启动第二个线程  
                tr.start();  
            }  
        }  
    }  
}  

package com.java.xiong.Tread16;

public class RunnableTest {

public static void main() {

RunnableTread runs=new RunnableTread();
//获取线程对象
Thread tr=new Thread(runs);
for (int i = 0; i < 100; i++) {
// 当前线程
System.out.println(Thread.currentThread().getName());
if (i == 10) {
// 启动第一个线程
tr.start();
// 启动第二个线程
tr.start();
}
}
}
}

使用Callable与Future来创建启动线程

  1.创建Callable的实现类,并冲写call()方法，该方法为线程执行体，并且该方法有返回值

  2.创建Callable的实例，并用FutuerTask类来包装Callable对象，该FutuerTask封装了Callable对象call()方法的返回值

  3.实例化FutuerTask类，参数为FutuerTask接口实现类的对象来启动线程

  4.通过FutuerTask类的对象的get()方法来获取线程结束后的返回值

[java]
view plain
copy
print?





package com.java.xiong.Tread16;  
  
import java.util.concurrent.Callable;  
import java.util.concurrent.FutureTask;  
  
public class CallableTest implements Callable<Integer> {  
  
    @Override  
    public Integer call() throws Exception {  
        // TODO Auto-generated method stub  
  
        int i = 0;  
        for (; i < 100; i++) {  
            // 当前线程  
            System.out.println("线程名" + i + ":" + Thread.currentThread());  
        }  
        return i;  
    }  
  
    public static void main(String[] args) {  
        CallableTest call = new CallableTest();  
        FutureTask<Integer> fu = new FutureTask<Integer>(call);  
        Thread th = new Thread(fu, "有返回值的线程");  
  
        for (int i = 0; i < 100; i++) {  
            // 当前线程  
            System.out.println(Thread.currentThread().getName());  
            if (i == 10) {  
                // 启动第一个线程  
                th.start();  
            }  
        }  
        try {  
            System.out.println("返回值是:" + fu.get());  
  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
  
}  

package com.java.xiong.Tread16;

import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;

public class CallableTest implements Callable<Integer> {

@Override
public Integer call() throws Exception {
// TODO Auto-generated method stub

int i = 0;
for (; i < 100; i++) {
// 当前线程
System.out.println("线程名" + i + ":" + Thread.currentThread());
}
return i;
}

public static void main(String[] args) {
CallableTest call = new CallableTest();
FutureTask<Integer> fu = new FutureTask<Integer>(call);
Thread th = new Thread(fu, "有返回值的线程");

for (int i = 0; i < 100; i++) {
// 当前线程
System.out.println(Thread.currentThread().getName());
if (i == 10) {
// 启动第一个线程
th.start();
}
}
try {
System.out.println("返回值是:" + fu.get());

} catch (Exception e) {
e.printStackTrace();
}
}

}