创建线程及线程池

2019-11-06 09:15:27

字体：大中小

来源：转载

供稿：网友

创建线程有两种实现方案 1、创建类实现Runnable接口 2、创建类继承Thread类

package Thread03;//1.实现Runnable//定义类实现 Runnable 接口 //实现 run 方法//把新线程要做的事写在 run 方法中//创建自定义的 Runnable 的子类对象mt2 //创建 new Thread(Runnable ) 对象, 传入 mt2 //调用 thread.start()开启新线程, 内部会自动调用 Runnable 的run()方法public class Thread2 implements Runnable { @Override public void run() { for (int i = 0; i < 1000; i++) { System.out.PRintln("这是自定义线程。。。。"); } }}package Thread03;public class Demo02 { public static void main(String[] args) { Thread2 thread2=new Thread2(); Thread thread = new Thread(thread2); thread.start(); for (int i = 0; i < 1000; i++) { System.out.println("这是主线程。。。"); } }}package Thread03;// 2.继承Thread// 步骤: //* 定义类继承 Thread//* 重写 run 方法//* 把新线程要做的事写在 run 方法中//* 创建自定义类的线程对象//* 开启新线程, 内部会自动执行 run 方法 public class Thread1 extends Thread{ public Thread1(String name){ super(name); } public Thread1(){ } public void run(){ for (int i = 0; i < 1000; i++) { System.out.println("这是自定义线程。。。。"+getName()); } }}package Thread03;public class Demo01 { public static void main(String[] args) { Thread1 thread1=new Thread1();//创建一个Thread对象 ,就是开启一条线程 thread1.setName("登录");//设置线程名称 Thread1 thread2=new Thread1("注册");//在Thread1中编写有参数的构造方法，也可以设置线程名字 thread1.start();//注意开启线程使用start()方法 thread2.start();//有开启了一个线程 for (int i = 0; i < 1000; i++) { System.out.println("这是主线程。。。。。"+Thread.currentThread().getName()); } }}

线程类还有其他一些方法，sleep(),join(),setDaemon()等。下面是线程的生命周期：线程生命周期程序启动一个新线程成本是比较高的，因为它涉及到要与操作系统进行交互。而使用线程池可以很好的提高性能，尤其是当程序中要创建大量生存期很短的线程时，更应该考虑使用线程池。线程池里的每一个线程代码结束后，并不会死亡，而是再次回到线程池中成为空闲状态，等待下一个对象来使用。 public static ExecutorService newCachedThreadPool() public static ExecutorService newFixedThreadPool(int nThreads) public static ExecutorService newSingleThreadExecutor() 这些方法的返回值是ExecutorService对象，该对象表示一个线程池，可以执行Runnable对象或者Callable对象代表的线程。它提供了submit方法。

案例演示，步骤：创建线程池对象创建Runnable实例提交Runnable实例关闭线程池

package Thread02;public class MyRun implements Runnable { @Override public void run() { for (int i = 0; i < 1000; i++) { System.out.println("my run........"+Thread.currentThread().getName()); } }}package Thread02;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;public class Demo01 { public static void main(String[] args) { //创建线程池对象 ExecutorService pool = Executors.newFixedThreadPool(3); //创建Runnable实例 MyRun myRun1 = new MyRun(); MyRun myRun2 = new MyRun(); MyRun myRun3 = new MyRun(); //提交Runnable实例 Future<?> submit1 = pool.submit(myRun1); Future<?> submit2 = pool.submit(myRun2); Future<?> submit3 = pool.submit(myRun3); //关闭线程池 pool.shutdown(); }}

匿名内部类方式使用多线程

package Thread03;public class Demo03 { public static void main(String[] args) { new Thread("登录"){ public void run(){ for (int i = 0; i < 1000; i++) { System.out.println("run..."+getName()); } } }.start(); for (int i = 0; i < 1000; i++) { System.out.println("run..."+Thread.currentThread().getName()); } }}package Thread03;public class Demo04 { public static void main(String[] args) { new Thread(new Runnable() { @Override public void run() { for (int i = 0; i < 1000; i++) { System.out.println("run..."+Thread.currentThread().getName()); } } }).start(); for (int i = 0; i < 1000; i++) { System.out.println("run..."+Thread.currentThread().getName()); } }}

上一篇：升级docker 1.13 后dockerd启动异常

下一篇：H5 下载文件到本地