java 线程学习
2016-08-06 00:00
225 查看
摘要: 线程的主要用法
效果如下:
![](http://static.oschina.net/uploads/img/201608/06110222_icE3.jpg)
选择我们运行的程序:
![](http://static.oschina.net/uploads/img/201608/06110222_2pnq.jpg)
监控运行状态
一、多线程的基本用法 package com.hxkj.websocket.runable; public class TicketRunable implements Runnable { private static Integer number = 100; @Override public void run() { for(int i=0;i<33;i++){ System.out.println(Thread.currentThread().getName()+"当前卖票的号数为:"+number--); } } public static void doThread(String name){ Thread thread = new Thread(new Runnable() { @Override public void run() { for(int i=0;i<33;i++){ System.out.println(Thread.currentThread().getName()+"当前卖票的号数为:"+number--); } } }); thread.start(); try { thread.join();//该方法是让线程执行结束了才结束主方法线程 } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static void main(String[] args) { /*TicketRunable ticketRunable = new TicketRunable(); new Thread(ticketRunable, "张三").start(); new Thread(ticketRunable, "李四").start(); new Thread(ticketRunable, "王五").start();*/ doThread("aa"); doThread("bb"); System.out.println("主线程结束了"); } } 二、线程池的使用 Java通过Executors提供四种线程池,分别为: newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。 newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。 newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。 newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。 (1) newCachedThreadPool 创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。示例代码如下: public class ThreadPoolExecutorTest { public static void main(String[] args) { ExecutorService cachedThreadPool = Executors.newCachedThreadPool(); for (int i = 0; i < 10; i++) { final int index = i; try { Thread.sleep(index * 1000); } catch (InterruptedException e) { e.printStackTrace(); } cachedThreadPool.execute(new Runnable() { public void run() { System.out.println(index); } }); } } } 线程池为无限大,当执行第二个任务时第一个任务已经完成,会复用执行第一个任务的线程,而不用每次新建线程。 (2) newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。示例代码如下: public class ThreadPoolExecutorTest { public static void main(String[] args) { ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3); for (int i = 0; i < 10; i++) { final int index = i; fixedThreadPool.execute(new Runnable() { public void run() { try { System.out.println(index); Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }); } } } 因为线程池大小为3,每个任务输出index后sleep 2秒,所以每两秒打印3个数字。 定长线程池的大小最好根据系统资源进行设置。如Runtime.getRuntime().availableProcessors() (3) newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。延迟执行示例代码如下: public class ThreadPoolExecutorTest { public static void main(String[] args) { ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5); scheduledThreadPool.schedule(new Runnable() { public void run() { System.out.println("delay 3 seconds"); } }, 3, TimeUnit.SECONDS); } } 表示延迟3秒执行。 定期执行示例代码如下: public class ThreadPoolExecutorTest { public static void main(String[] args) { ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5); scheduledThreadPool.scheduleAtFixedRate(new Runnable() { public void run() { System.out.println("delay 1 seconds, and excute every 3 seconds"); } }, 1, 3, TimeUnit.SECONDS); } } 表示延迟1秒后每3秒执行一次。 (4) newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。示例代码如下: public class ThreadPoolExecutorTest { public static void main(String[] args) { ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor(); for (int i = 0; i < 10; i++) { final int index = i; singleThreadExecutor.execute(new Runnable() { public void run() { try { System.out.println(index); Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } } }); } } } 结果依次输出,相当于顺序执行各个任务。 你可以使用JDK自带的监控工具来监控我们创建的线程数量,运行一个不终止的线程,创建指定量的线程,来观察: 工具目录:C:\Program Files\Java\jdk1.8\bin\jconsole.exe 运行程序做稍微修改: public class ThreadPoolExecutorTest { public static void main(String[] args) { ExecutorService singleThreadExecutor = Executors.newCachedThreadPool(); for (int i = 0; i < 100; i++) { final int index = i; singleThreadExecutor.execute(new Runnable() { public void run() { try { while(true) { System.out.println(index); Thread.sleep(10 * 1000); } } catch (InterruptedException e) { e.printStackTrace(); } } }); try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } } } } 效果如下: 选择我们运行的程序: 监控运行状态
效果如下:
![](http://static.oschina.net/uploads/img/201608/06110222_icE3.jpg)
选择我们运行的程序:
![](http://static.oschina.net/uploads/img/201608/06110222_2pnq.jpg)
监控运行状态
相关文章推荐
- java线程学习基础
- Java线程学习和总结
- java多线程学习五:线程间的通信
- 关于java 线程学习
- java学习之进程和线程
- java学习日记(线程)
- Java多线程学习 (一) 前台、后台线程
- java多线程学习三:联合线程
- 今天学习了JAVA程序、线程、进程的区别
- java Thread类 线程学习 一:
- java线程初步学习
- Java线程学习和总结
- java 线程学习(一)
- Java线程学习
- Java线程学习11.30
- Java 学习笔记 (5) - 线程 Thread
- Java线程学习和总结
- JAVA学习【知】线程
- Java基础学习笔记(十)线程的创建总结
- java Thread类 线程学习 一: