前言：对于java多线程的资料数不胜数，我们这里只是在学习后简单地总结一下并给出一些小例子,本文适合java初学者。不过在开始之前，我们还是要弄明白一个问题——线程和进程有什么区别？其实一个进程是一个独立的运行环境，它可以被看作一个程序或者一个应用，而线程是在进程中执行的一个任务，线程是进程的子集，一个进程可以有很多线程，每条线程并行执行不同的任务。不同的进程使用不同的内存空间，而所有的线程共享一片相同的内存空间。别把它和栈内存搞混，每个线程都拥有单独的栈内存用来存储本地数据。
1.创建线程的方法
创建线程方法一：继承Thread类，使用子类创建
编写继承Thread子类MyThread
//MyThread.java
public class MyThread extends Thread{
private String name;
public MyThread(String name){
this.name= name;
}
//继承Thread类必须重写run()方法
@Override
public void run() {
System.out.println("name:" + name + "子线程ID："
+ Thread.currentThread().getId());
}
}
在main方法里面编写代码：
System.out.println("主线程ID："+ Thread.currentThread().getId());
//创建多个子线程
for(int i = 0; i < 5; i++){
String threadName = "Thread" + (i + 1);
MyThread thread = new MyThread(threadName);
thread.start();
}
//注：直接调用Thread的run方法，并不会在新的线程上执行，而是跟普通方法调用一样，在当前线程上执行
MyThread threadSpec = new MyThread("ThreadSpec"); //特例
threadSpec.run();
运行结果
说明：启动线程是通过start()方法，而不是调用run()方法，在线程获取cpu执行时间的时候会自动调用run()方法。
创建线程方法二：实现Runnable接口，在Runnable上定义任务，然后将Runnable交由Thread执行
编写实现Runnable的实现类MyRunnable
//MyRunnable.java
public class MyRunnable implements Runnable {
public MyRunnable(){}
//实现Runnable接口必须重写其run方法
@Override
public void run() {
System.out.println("子线程ID："+ Thread.currentThread().getId());
}
}
在main方法里面编写代码：
MyRunnable runnable = new MyRunnable();
Thread thread = new Thread(runnable);
thread.start();
运行结果
说明：和方法一对比，方法二可能有些啰嗦，但是Java只允许单继承，如果实际情况中类需要继承其他类，则只能选择方法二来实现多线程。
2.使用ExecutorService、Callable、Future实现有返回结果的多线程
先编写实现Callable的实现类MyCallable
//MyCallable.java
public class MyCallable implements Callable {
private String taskIndex;
MyCallable(String taskIndex){
this.taskIndex = taskIndex;
}
@Override
public Object call() throws Exception {
System.out.println(taskIndex + "号任务启动");
Date startDate = new Date();
Thread.sleep(1000);
Date endDate = new Date();
long time = endDate.getTime() - startDate.getTime();
System.out.println(taskIndex + "号任务终止");
return taskIndex + "号任务返回运行结果，当前任务执行【" + time +"毫秒】";
}
}
在main方法里面编写代码：
//使用ExecutorService、Callable、Future实现有返回结果的多线程
System.out.println("------程序开始运行-----");
Date startDate = new Date();
int taskSize = 5;
//创建一个线程池
ExecutorService pool = Executors.newFixedThreadPool(taskSize);
//创建多个有返回值的任务
List list =new ArrayList<>();
for(int i =0;i < taskSize;i++){
Callable c = new MyCallable(i +"");
//执行任务并获取Future对象
Future f = pool.submit(c);
list.add(f);
}
//关闭线程池
pool.shutdown();
//获取所有并发任务的运行结果
for(Future f : list){
//从Future对象上获取任务的返回值
System.out.println(f.get().toString());
}
Date endDate =new Date();
System.out.println("------程序结束运行-----,程序运行了【"+ (endDate.getTime() - startDate.getTime()) +"毫秒】");
运行结果
说明：ExecutorService、Callable、Future这个对象实际上都是属于Executor框架中的功能类。想要详细了解Executor框架的可以访问Java程序员必备知识-多线程框架Executor详解。实现Callable接口，执行Callable任务后，可以获取一个Future的对象，在该对象上调用get就可以获取到Callable任务返回的Object了。
注：以上内容是学习java 多线程后的一个简单的总结，如果有错误，请各位指出，也欢迎大家前来拍砖，灰常感谢！
网友评论