当前位置: 首页 > 图灵资讯 > 技术篇> Java线程实现/创建方式

Java线程实现/创建方式

来源:图灵教育
时间:2023-06-28 14:27:55

1.继承Thread类

Thread类本质上是实现了Runnable接口的一个实例,代表一个线程的实例。启动线程的唯一方法就是通过Thread类的start()实例方法。start()方法是一个native方法,它将启动一个新线程,并执行run()方法。

public class MyThread extends Thread {  public void run() {  System.out.println("MyThread.run()");  } } MyThread myThread1 = new MyThread(); myThread1.start();

2.实现Runnable接口

public class MyThread extends OtherClass implements Runnable {  public void run() {  System.out.println("MyThread.run()");  } }//启动 MyThread,需要首先实例化一个 Thread,并传入自己的 MyThread 实例:MyThread myThread = new MyThread(); Thread thread = new Thread(myThread); thread.start(); //事实上,当传入一个 Runnable target 参数给 Thread 后,Thread 的 run()方法就会调用target.run()public void run() {  if (target != null) {  target.run();  } }

3.ExecutorService、Callable<Class>、Future有返回值线程

有返回值的任务必须实现Callable接口,类似的,无返回值的任务必须Runnable接口。执行Callable任务后,可以获取一个Future的对象,在该对象上调用get就可以获取到Callable任务返回的Object了,再结合线程池接口ExecutorService就可以实现传说中有返回结果的多线程了。

//创建一个线程池ExecutorService pool = Executors.newFixedThreadPool(taskSize);// 创建多个有返回值的任务List<Future> list = new ArrayList<Future>(); 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("res:" + f.get().toString()); }

4.基于线程池的方式

线程和数据库连接这些资源都是非常宝贵的资源。那么每次需要的时候创建,不需要的时候销毁,是非常浪费资源。那就使用线程池。

// 创建线程池 ExecutorService threadPool = Executors.newFixedThreadPool(10);   while(true) {     threadPool.execute(new Runnable() { // 提交多个线程任务,并执行     @Override     public void run() {     System.out.println(Thread.currentThread().getName() + " is running ..");       try {       Thread.sleep(3000);       } catch (InterruptedException e) {       e.printStackTrace();       }     }     });   }}

5.四种线程池

Java里面线程池的顶级接口是Executor,但是严格意义上讲Executor并不是一个线程池,而只是一个执行线程的工具。真正的线程池接口是ExecutorService。

newCacheedThreadPool:创建一个可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们。对于执行很多短期异步任务的程序而言,这些线程池通常可提高程序性能。调用execute将重用以前构造的线程(如果线程可用)。如果现有线程没有可用的,则创建一个新线程并添加到池中。终止并从缓存中移除那些已有60秒钟未被使用的线程。因此,长时间保持空闲的线程池不会使用任何资源。

newFixedThreadPool:创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程。在任意点,在大多数nThreads线程会处于处理任务的活动状态。如果在所有线程处于活动状态时提交附加任务,则在有可用线程之前,附加任务将在队列中等待。如果在关闭前的执行期间由于失败而导致线程终止,那么一个新线程将代替它执行后续的任务(如果需要)。在某个线程被显示地关闭之前,池中的线程将一直存在。

newScheduledThreadPool:创建一个线程池,它可安排在给定延迟后运行命令或定期地执行。

newSingleThreadExecutor:返回一个线程池(这个线程池只有一个),这个线程池可以在线程死后(或发生异常时)重新启动一个线程来替代原来的线程继续执行下去。