线程的三种创建方法
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();
}
}
}
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();
}
}
}
相关文章推荐
- 验证邮箱是否存在原理
- java Math.floor,Math.ceil,Math.rint,Math.round用法详解
- uvalive 3616
- 浅谈对主成分分析(PCA)算法的理解
- C#高级编程----反射的小结
- UVa-12166 Equilibrium Mobile
- Nginx负载均衡配置实例详解
- (素材源码)swanzhu学IOS(三)打飞机
- 在visual studio 2010中调用ffmpeg
- 伊斯坦布尔之旅第一站:韩国仁川机场免费中转旅游
- Linux 下面安装redis
- Android之SDK如何更新
- NSURLConnection使用
- 微软源代码管理工具TFS2013安装与使用详细图文教程(Vs2013)
- HDU2303(数论)大整数求余+素数筛选
- 阿里云服务器ubuntu安装java运行环境
- 蓝牙的RSSI转换为信号强度百分百
- HDU - 4287 Intelligent IME 字典树
- HDU-1686-Oulipo
- POJ 1001(Exponentiation)