ThreadByImplementRunnable tb = new ThreadByImplementRunnable();
Thread t = new Thread(tb);
/*
这一步很关键,只有调用start方法,才会通过start方法调用系统的方法来真正创建一个线程
*/
t.start();
继承Thread:
public class ThreadByExtendThread extends Thread {
@Override
public void run() {
System.out.println("A thread by extending Thread class");
}
}
Thread这个类本身就是实现Runnable接口,通过继承Thread,来启动一个线程最为简单。代码为:
ThreadByExtendThread t = new ThreadByExtendThread();
t.start();
上面提到的都是最基本的创建一个线程的方法。但是只要接触过线程,基本都会通过线程池的概念。在jdk中,就提供了创建线程池的技术。
在java.util.concurrent这个包下,有一个类Executors,这个类提供了多个创建不同类型线程池的static方法。
newSingleThreadExecutor() :相当于我们平常所说的单例模式,只会同时存在一个线程对象。使用这个方法的测试代码如下:
public class ThreadTest {
public static void main(String[] args) {
ThreadForSingleThread t1 = new ThreadForSingleThread();
ThreadForSingleThread t2 = new ThreadForSingleThread();
Executor pool1 = Executors.newSingleThreadExecutor();
pool1.execute(t1);
pool1.execute(t2);
}
private static final class ThreadForSingleThread implements Runnable{
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Override
public void run() {
System.out.println("start time:" + sdf.format(new Date(System.currentTimeMillis())));
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("end time:" +sdf.format(new Date(System.currentTimeMillis())));
}
}
}
输出为:
start time:2017-05-29 13:53:40
end time:2017-05-29 13:53:45
start time:2017-05-29 13:53:45
end time:2017-05-29 13:53:50
根据结果集分析,在上一个线程执行完毕之前,下一个线程并没有任何输出,因此可以推测在运行期间,仅仅创建了一个线程。具体代码请查看源代码。
newFixedThreadPool(int nThreads):创建一个可以同时存在nThreads个数量的线程池。创建线程的方式如下:
Thread t1 = new Thread();
Thread t2 = new Thread();
Thread t3 = new Thread();
Executor pool = Executors.newFixedThreadPool(3);
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
newCachedThreadPool():根据实际的需要动态的改变线程池中的线程对象,数目不固定。创建线程的如下:
Thread t1 = new Thread();
Thread t2 = new Thread();
Thread t3 = new Thread();
Executor pool = Executors.newCachedThreadPool(3);
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);