您的位置:首页 > 其它

线程的三种创建方法

2015-08-07 20:15 393 查看
//使用继承Thread的方法来创建线程类时,多个线程之间无法共享线程类的实例变量

public class FirstThread extends Thread{

private int i;
public void run(){
for (; i < 100; i++) {
//当线程类继承Thread类时,直接使用this即可获取当前线程
//Thread对象的getName()返回当前线程的名字
//因此可以直接调用getName()方法返回当前线程的名字
//这点与实现Runnable接口有区别
System.out.println(getName()+" "+i);
}
}
public static void main(String[] args) {
for (int i = 0; i < 100; i++) {
System.out.println(Thread.currentThread().getName()+" "+i);
if (i == 20) {
new FirstThread().start();
new FirstThread().start();
}
}
}
}

public class SecondThread implements Runnable{
private int i;
public void run(){
for (; i < 100; i++) {
//当线程类实现Runnable接口时
//如果想获取当前线程,只能使用Thread.currentThread()方法
System.out.println(Thread.currentThread().getName()+" "+i);
}
}
public static void main(String[] args) {
for (int i = 0; i < 100; i++) {
System.out.println(Thread.currentThread().getName()+" "+i);
if (i == 20) {
SecondThread st = new SecondThread();
//下面这两个线程的执行顺序与他们的创建顺序没有关系
new Thread(st,"新线程1").start();
new Thread(st,"新线程2").start();
}
}
}

}

//从运行结果来看,两个子线程的变量i是连续的,也就是采用Runnable接口的方式创建的多个线程可以共享

//线程类的实例属性。(就是说,两个子线程的i加起来一共只出现100次,因为可以共享)这是因为在这种方式下,

//程序所创建的Runnable对象只是线程的target,而多个线程可以共享同一个target,所以多个线程可以共享

//同一个线程类(实际上应该是线程类的target类)的实例属性。

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.FutureTask;

/*

 * 创建有返回值的线程的步骤如下:

 * 1.创建Callable接口的实现类,并实现call()方法,该call()方法将作为线程执行体,且该call()方法有返回值

 * 2.创建Callable实现类的实例,使用FutureTask类来包装Callable对象,该FutureTask对象封装了该Callable对象的 call()方法的返回值。

 * 3.使用FutureTask对象作为Thread对象的target创建并启动新线程。

 * 4.调用FutureTask对象的get()方法来获得子线程执行结束后的返回值。

 */

public class ThirdThread implements Callable<Integer>{

@Override
public Integer call() throws Exception {
int i = 0;
for(;i<100;i++){
System.out.println(Thread.currentThread().getName()+" 的循环变量i的值: "+i);
}
return i;
}
public static void main(String[] args) {
ThirdThread rt = new ThirdThread();
FutureTask<Integer> task = new FutureTask<Integer>(rt);
for (int i = 0; i < 100; i++) {
System.out.println(Thread.currentThread().getName()+"的循环变量i的值: "+i);
if (i == 20) {
new Thread(task,"有返回值的线程:").start();
}
}
try {
System.out.println("子线程的返回值: "+task.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}

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