多线程调用同一个对象的方法_多线程之如何创建和使用线程

一、创建线程和使用线程方式

1.1 继承Thread

让线程类继承自Thread类，然后重写run()，把需要多线程调用的代码放到run()中。但是需要开启线程的时候不能调用run方法，而是需要调用start()方法。

/***  本类用于演示第一种实现多线程的方式*/
class MyThread extends Thread{// 需要我们使用多进程运行的代码就写在run方法里@Overridepublic void run() {		for (int i = 1; i < 5; i++) {	System.out.println(Thread.currentThread().getName() + "线程正在运行~~~~~~" + i);}}
}
public class ThreadDemo01 extends Thread{public static void main(String[] args) {MyThread thread = new MyThread();thread.start();for (int i = 1; i < 5; i++) {	System.out.println(Thread.currentThread().getName() + "线程正在运行======" + i);}}
}

运行结果：(两个线程同时运行，争抢cpu，每次执行结果不固定)

12.2 实现Runnable接口

需要我们创建的线程类实现Runnable接口。实现run方法，把需要多线程调用的代码写在run方法中。由于Runnable接口中只有一个run方法，所以不能直接调用start()。这个时候需要创建一个Thread类的对象来帮助我们开启线程。创建这个Thread类对象的时候需要将我们的线程类作为参数传递给Thread对象。

/***  本类用于演示第二种实现多线程的方式*/
class MyThread2 implements Runnable{// 需要我们使用多进程运行的代码就写在run方法里@Overridepublic void run() {		for (int i = 1; i < 5; i++) {	System.out.println(Thread.currentThread().getName() + "线程正在运行~~~~~~" + i);}}
}public class ThreadDemo02 {public static void main(String[] args) {	 MyThread2 myThread2 = new MyThread2();// myThread2.run();// 由于Runable接口只有一个run方法，所以实现Runnable接口的这种方式，线程本身没有start方法。// 但是必须要调用start方法才能开启多线程，所以需要创建Thread类的对象，把我们的线程类作为参数传递给构造方法。Thread thread = new Thread(myThread2);thread.start();for (int i = 1; i < 5; i++) {	System.out.println(Thread.currentThread().getName() + "线程正在运行~~~~~~" + i);}	}
}

运行结果：(两个线程同时运行，争抢cpu，每次执行结果不固定)

2.3 实现Callable接口

采用实现Callable接口实现多线程启动方式以上两种的方式不太一样，下面就看一下怎样启动采用实现Callable接口的线程。

第一步：定义一个类实现Callable接口，并且指定call()返回值的类型。将业务逻辑写在call()方法中。

第二步：创建FutureTask对象，并将Callable对象传入FutureTask的构造方法中。

第三步：实例化Thread对象，并在构造方法中传入FurureTask对象。

第四步：启动线程

/***  本类用于演示第三种实现多线程的方式*/
class MyCallable implements Callable<String>{@Overridepublic String call() throws Exception {for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + "线程正在运行~~~~~" + i);}return "MyCallable接口执行完成！";}	}
public class ThreadDemo03 {public static void main(String[] args) throws  Exception {// 1、创建FutureTask实例，创建MyCallable实例FutureTask<String> futureTask = new FutureTask<>(new MyCallable());// 2、创建Thread实例，来执行futureTaskThread thread = new Thread(futureTask);thread.start();// 3、主线程for (int i = 0; i < 10; i++) {System.out.println(Thread.currentThread().getName() + "线程正在运行~~~~~" + i);}// 4、获取执行结果System.out.println(futureTask.get());}
}

运行结果：

1.4 线程池

在一个应用程序中，我们需要多次使用线程，也就意味着，我们需要多次创建并销毁线程。而创建并销毁线程的过程势必会消耗内存。而在Java中，内存资源是及其宝贵的，所以，我们就提出了线程池的概念。

线程池：Java中开辟出了一种管理线程的概念，这个概念叫做线程池，从概念以及应用场景中，我们可以看出，线程池的好处，就是可以方便的管理线程，也可以减少内存的消耗。

那么，我们应该如何创建一个线程池那?Java中已经提供了创建线程池的一个类：Executor而我们创建时，一般使用它的子类：ThreadPoolExecutor。

第一步：使用Executors获取线程池对象；

第二步：通过线程池获取对象获取线程并执行Runable子类实例；

class MyThread4 implements Runnable{// 需要我们使用多进程运行的代码就写在run方法里@Overridepublic void run() {		for (int i = 1; i < 5; i++) {	System.out.println(Thread.currentThread().getName() + "线程正在运行~~~~~~" + i);}}
}
public class ThreadDemo04 {public static void main(String[] args) {	// 第一步：使用Executors获取线程池对象；ExecutorService executorService = Executors.newFixedThreadPool(10);// 第二步：通过线程池获取对象获取线程并执行Runable实例；executorService.execute(new MyThread4());		for (int i = 1; i < 5; i++) {	System.out.println(Thread.currentThread().getName() + "线程正在运行~~~~~~" + i);}		}
}

运行结果：