当前位置:首页 > 开发 > 编程语言 > 多线程 > 正文

Java线程的创建

发表于: 2012-10-19   作者:cug_xw   来源:转载   浏览:
摘要: 很多书上介绍Java的线程创建有两种方式,一种是继承Thread类,一种是实现Runnable接口。实际上Runnable接口只有一个run方法,Thread也是实现了Runnable接口的,但是无论哪种方式都必须借助Thread类,下面列举了创建线程的两种方式: ->方式一:继承Thread类 public class ChildThread extends Thread {

很多书上介绍Java的线程创建有两种方式,一种是继承Thread类,一种是实现Runnable接口。实际上Runnable接口只有一个run方法,Thread也是实现了Runnable接口的,但是无论哪种方式都必须借助Thread类,下面列举了创建线程的两种方式:

->方式一:继承Thread类

public class ChildThread extends Thread {

	/**
	 * 覆盖run方法,编写线程执行的核心代码
	 */
	@Override
	public void run() {
		System.out.println("线程" + Thread.currentThread().getName() + "执行了...");
	}
	
	public static void main(String[] args) {
		//启动线程
		new ChildThread().start();
	}
	
}

->方式二:实现Runnable接口,将Runnable对象作为Thread的目标对象(targetObject)

public class ThreadTargetObject implements Runnable {

	/**
	 * 实现run方法,编写线程执行的核心代码
	 */
	@Override
	public void run() {
		System.out.println("线程" + Thread.currentThread().getName() + "执行了...");
	}

	public static void main(String[] args) {
		//启动线程
		new Thread(new ThreadTargetObject()).start();
	}
}

  注意:必须通过start方法来启动线程,直接调用run方法是无法异步执行线程的,因为start方法会真正调用native方法创 建线程,并调用run方法。

 

当然,以上方法都是我们自己通过new关键字来创建的线程对象,很多时候我们在编程多线程程序的时候会用到线程池,因为创建过多的线程会消耗系统很多的资源,而且每次创建和销毁都会占用一些CPU时间,每个线程运行起来也会变慢,线程池会帮助我们创建线程和分配线程,实现线程对象的重用,这样会更高效,JDK5以后加入了并发包,也就是java.lang.concurrent包,我们也没必要自己去写线程池了,下面是线程池的使用代码:

package com.cugxw.thread;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

public class ThreadPoolTest {
	public static void main(String args[]) throws InterruptedException {
		
		System.out.println("-----------------------测试newFixedThreadPool----------");
		
		// 在线程池中创建3个线程
		ExecutorService execs = Executors.newFixedThreadPool(3);
		// 创建100 个线程目标对象
		for (int index = 0; index < 10; index++) {
			Runnable run = new ThreadTO(index);
			// 执行线程目标对象
			execs.execute(run);
		}
		execs.shutdown();
		
		System.out.println("-----------------------测试newCachedThreadPool-------");
		
		//使用线程池cache策略
		ExecutorService execsCached = Executors.newCachedThreadPool();
		// 创建10 个线程目标对象
		for (int index = 0; index < 10; index++) {
			Runnable run = new ThreadTO(index);
			// 执行线程目标对象
			execsCached.execute(run);
		}
		execsCached.shutdown();
		
		System.out.println("-----------------------测试newScheduledThreadPool------");
		
		// 在线程池中创建3个线程
		ExecutorService execsSche = Executors.newScheduledThreadPool(3);
		// 创建10 个线程目标对象
		for (int index = 0; index < 10; index++) {
			Runnable run = new ThreadTO(index);
			// 执行线程目标对象
			execsSche.execute(run);
		}
		execsSche.shutdown();
		
		System.out.println("-----------------------测试defaultThreadFactory-------");
		
		//获取一个线程工厂类,用于创建新的线程
		ThreadFactory tf = Executors.defaultThreadFactory();
		tf.newThread(new ThreadTO(100)).start();
		tf.newThread(new ThreadTO(101)).start();
		tf.newThread(new ThreadTO(102)).start();
		tf.newThread(new ThreadTO(103)).start();
		tf.newThread(new ThreadTO(104)).start();
		
	}
}

// 线程目标对象
class ThreadTO implements Runnable {
	int index = 0;

	public ThreadTO(int index) {
		this.index = index;
	}

	@Override
	public void run() {
		System.out.println("线程:" + Thread.currentThread().getName() 
				+ "调用了目标对象" + index);
	}
}

 

Java线程的创建

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号