先看幾個(gè)概念：
線程：進(jìn)程中負(fù)責(zé)程序執(zhí)行的執(zhí)行單元。正在運(yùn)行的程序，是系統(tǒng)進(jìn)行資源分配和調(diào)用的獨(dú)立單位。每一個(gè)進(jìn)程都有它自己的內(nèi)存空間和系統(tǒng)資源。
是進(jìn)程中的單個(gè)順序控制流，是一條執(zhí)行路徑,一個(gè)進(jìn)程如果只有一條執(zhí)行路徑，則稱為單線程程序。
一個(gè)進(jìn)程如果有多條執(zhí)行路徑，則稱為多線程程序。
線程池：基本思想還是一種對(duì)象池的思想，開辟一塊內(nèi)存空間，里面存放了眾多(未死亡)的線程，池中線程執(zhí)行調(diào)度由池管理器來處理。當(dāng)有線程任務(wù)時(shí)，從池中取一個(gè)，執(zhí)行完成后線程對(duì)象歸池，這樣可以避免反復(fù)創(chuàng)建線程對(duì)象所帶來的性能開銷，節(jié)省了系統(tǒng)的資源。
總結(jié):
- 如果程序只有一條執(zhí)行路徑,那么該程序是單線程程序.
- 如果程序有多條執(zhí)行路徑,那么該程序是多線程程序.
使用
package cn.itcast_11;
/*
* 匿名內(nèi)部類的格式：
* new 類名或者接口名() {
* 重寫方法;
* };
* 本質(zhì)：是該類或者接口的子類對(duì)象。
*/
public class ThreadDemo {
public static void main(String[] args) {
// 繼承Thread類來實(shí)現(xiàn)多線程
new Thread() {
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println(Thread.currentThread().getName() + ":"
+ x);
}
}
}.start();
// 實(shí)現(xiàn)Runnable接口來實(shí)現(xiàn)多線程
new Thread(new Runnable() {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println(Thread.currentThread().getName() + ":"
+ x);
}
}
}) {
}.start();
// 更有難度的
new Thread(new Runnable() {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println("hello" + ":" + x);
}
}
}) {
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println("world" + ":" + x);
}
}
}.start();
}
}
線程求和案例
package cn.itcast_10;
import java.util.concurrent.Callable;
/*
* 線程求和案例
*/
public class MyCallable implements Callable<Integer> {
private int number;
public MyCallable(int number) {
this.number = number;
}
@Override
public Integer call() throws Exception {
int sum = 0;
for (int x = 1; x <= number; x++) {
sum += x;
}
return sum;
}
}
package cn.itcast_10;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
/*
* 多線程實(shí)現(xiàn)的方式3：
* A:創(chuàng)建一個(gè)線程池對(duì)象，控制要?jiǎng)?chuàng)建幾個(gè)線程對(duì)象。
* public static ExecutorService newFixedThreadPool(int nThreads)
* B:這種線程池的線程可以執(zhí)行：
* 可以執(zhí)行Runnable對(duì)象或者Callable對(duì)象代表的線程
* 做一個(gè)類實(shí)現(xiàn)Runnable接口。
* C:調(diào)用如下方法即可
* Future<?> submit(Runnable task)
* <T> Future<T> submit(Callable<T> task)
* D:我就要結(jié)束，可以嗎?
* 可以。
*/
public class CallableDemo {
public static void main(String[] args) throws InterruptedException, ExecutionException {
// 創(chuàng)建線程池對(duì)象
ExecutorService pool = Executors.newFixedThreadPool(2);
// 可以執(zhí)行Runnable對(duì)象或者Callable對(duì)象代表的線程
Future<Integer> f1 = pool.submit(new MyCallable(100));
Future<Integer> f2 = pool.submit(new MyCallable(200));
// V get()
Integer i1 = f1.get();
Integer i2 = f2.get();
System.out.println(i1);
System.out.println(i2);
// 結(jié)束
pool.shutdown();
}
}
線程池使用案例
綜合使用案例一
需求：從數(shù)據(jù)庫(kù)中獲取url，并利用httpclient循環(huán)訪問url地址，并對(duì)返回結(jié)果進(jìn)行操作
分析：由于是循環(huán)的對(duì)多個(gè)url進(jìn)行訪問并獲取數(shù)據(jù)，為了執(zhí)行的效率，考慮使用多線程，url數(shù)量未知如果每個(gè)任務(wù)都創(chuàng)建一個(gè)線程將消耗大量的系統(tǒng)資源，最后決定使用線程池。
public class GetMonitorDataService {
private Logger logger = LoggerFactory.getLogger(GetMonitorDataService.class);
@Resource
private MonitorProjectUrlMapper groupUrlMapper;
@Resource
private MonitorDetailBatchInsertMapper monitorDetailBatchInsertMapper;
public void sendData(){
//調(diào)用dao查詢所有url
MonitorProjectUrlExample example=new MonitorProjectUrlExample();
List<MonitorProjectUrl> list=groupUrlMapper.selectByExample(example);
logger.info("此次查詢數(shù)據(jù)庫(kù)中監(jiān)控url個(gè)數(shù)為"+list.size());
//獲取系統(tǒng)處理器個(gè)數(shù)，作為線程池?cái)?shù)量
int nThreads=Runtime.getRuntime().availableProcessors();
//定義一個(gè)裝載多線程返回值的集合
List<MonitorDetail> result= Collections.synchronizedList(new ArrayList<MonitorDetail>());
//創(chuàng)建線程池，這里定義了一個(gè)創(chuàng)建線程池的工具類，避免了創(chuàng)建多個(gè)線程池，ThreadPoolFactoryUtil可以使用單例模式設(shè)計(jì)
ExecutorService executorService = ThreadPoolFactoryUtil.getExecutorService(nThreads);
//遍歷數(shù)據(jù)庫(kù)取出的url
if(list!=null&&list.size()>0) {
for (MonitorProjectUrl monitorProjectUrl : list) {
String url = monitorProjectUrl.getMonitorUrl();
//創(chuàng)建任務(wù)
ThreadTask threadTask = new ThreadTask(url, result);
//執(zhí)行任務(wù)
executorService.execute(threadTask);
//注意區(qū)分shutdownNow
executorService.shutdown();
try {//等待直到所有任務(wù)完成
executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.MINUTES);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//對(duì)數(shù)據(jù)進(jìn)行操作
saveData(result);
}
}
任務(wù)
public class ThreadTask implements Runnable{
//這里實(shí)現(xiàn)runnable接口
private String url;
private List<MonitorDetail> list;
public ThreadTask(String url,List<MonitorDetail> list){
this.url=url;
this.list=list;
}
//把獲取的數(shù)據(jù)進(jìn)行處理
@Override
public void run() {
MonitorDetail detail = HttpClientUtil.send(url, MonitorDetail.class);
list.add(detail);
}
}
綜合使用案例二(countDownLatch)
package com.br.lucky.utils;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
/**
* @author 10400
* @create 2018-04-19 20:38
*/
public class FatureTest {
//1、配置線程池
private static ExecutorService es = Executors.newFixedThreadPool(20);
//2、封裝響應(yīng)Feature
class BizResult{
public String orderId;
public String data;
public String getOrderId() {
return orderId;
}
public void setOrderId(String orderId) {
this.orderId = orderId;
}
public String getData() {
return data;
}
public void setData(String data) {
this.data = data;
}
}
//3、實(shí)現(xiàn)Callable接口
class BizTask implements Callable {
private String orderId;
private Object data;
//可以用其他方式
private CountDownLatch countDownLatch;
public BizTask(String orderId, Object data, CountDownLatch countDownLatch) {
this.orderId = orderId;
this.data = data;
this.countDownLatch = countDownLatch;
}
@Override
public Object call() {
try {
//todo business
System.out.println("當(dāng)前線程Id = " + this.orderId);
BizResult br = new BizResult();
br.setOrderId(this.orderId);
br.setData("some key about your business" + this.getClass());
return br;
}catch (Exception e){
e.printStackTrace();
}finally {
//線程結(jié)束時(shí)，將計(jì)時(shí)器減一
countDownLatch.countDown();
}
return null;
}
}
/**
* 業(yè)務(wù)邏輯入口
*/
public List<Future> beginBusiness() throws InterruptedException {
//模擬批量業(yè)務(wù)數(shù)據(jù)
List<String> list = new ArrayList<>();
for (int i = 0 ; i < 1000 ; i++) {
list.add(String.valueOf(i));
}
//設(shè)置計(jì)數(shù)器
CountDownLatch countDownLatch = new CountDownLatch(list.size());
//接收多線程響應(yīng)結(jié)果
List<Future> resultList = new ArrayList<>();
//begin thread
for( int i = 0 ,size = list.size() ; i<size; i++){
//todo something befor thread
resultList.add(es.submit(new BizTask(list.get(i), null, countDownLatch)));
}
//wait finish
countDownLatch.await();
return resultList;
}
public static void main(String[] args) throws InterruptedException {
FatureTest ft = new FatureTest();
List<Future> futures = ft.beginBusiness();
System.out.println("futures.size() = " + futures.size());
//todo some operate
System.out.println(" ==========================end========================= " );
}
}
綜合使用案例三(future.get())
package com.br.lucky.utils;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
/**
* @author 10400
* @create 2018-04-19 20:38
*/
public class FatureTest {
//1、配置線程池
private static ExecutorService es = Executors.newFixedThreadPool(20);
//2、封裝響應(yīng)Feature
class BizResult{
public String orderId;
public String data;
public String getOrderId() {
return orderId;
}
public void setOrderId(String orderId) {
this.orderId = orderId;
}
public String getData() {
return data;
}
public void setData(String data) {
this.data = data;
}
}
//3、實(shí)現(xiàn)Callable接口
class BizTask implements Callable {
private String orderId;
private Object data;
public BizTask(String orderId, Object data) {
this.orderId = orderId;
this.data = data;
}
@Override
public Object call() {
try {
//todo business
System.out.println("當(dāng)前線程Id = " + this.orderId);
BizResult br = new BizResult();
br.setOrderId(this.orderId);
br.setData("some key about your business" + this.getClass());
Thread.sleep(3000);
return br;
}catch (Exception e){
e.printStackTrace();
}
return null;
}
}
/**
* 業(yè)務(wù)邏輯入口
*/
public List<Future> beginBusiness() throws InterruptedException, ExecutionException {
//模擬批量業(yè)務(wù)數(shù)據(jù)
List<String> list = new ArrayList<>();
for (int i = 0 ; i < 100 ; i++) {
list.add(String.valueOf(i));
}
//接收多線程響應(yīng)結(jié)果
List<Future> resultList = new ArrayList<>();
//begin thread
for( int i = 0 ,size = list.size() ; i<size; i++){
//todo something befor thread
Future future = es.submit(new BizTask(list.get(i), null));
resultList.add(future);
}
for (Future f : resultList) {
f.get();
}
System.out.println(" =====多線程執(zhí)行結(jié)束====== ");
//wait finish
return resultList;
}
public static void main(String[] args) throws InterruptedException, ExecutionException {
FatureTest ft = new FatureTest();
List<Future> futures = ft.beginBusiness();
System.out.println("futures.size() = " + futures.size());
//todo some operate
System.out.println(" ==========================end========================= " );
}
}
創(chuàng)建線程 方式一
package com.toltech.springboot.test;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27 兩種創(chuàng)建方式:
* 方式一:繼承Thread類
* 步驟:
* A: 自定義類繼承Thread類
* B: 重寫Run方法
* C: 創(chuàng)建對(duì)象
* D: 啟動(dòng)線程
*/
public class MyThreadDemo extends Thread {
public MyThreadDemo(){}
public MyThreadDemo(String name){
super(name);
}
@Override
public void run() {
for (int i = 0; i <= 100; i++) {
System.out.println(getName());
}
}
}
/**
* 獲取線程名稱
*public final String getName();
*/
class Test{
public static void main(String[] args) {
/* // 創(chuàng)建對(duì)象
MyThreadDemo myThreadDemo1 = new MyThreadDemo();
MyThreadDemo myThreadDemo2 = new MyThreadDemo();
// 設(shè)置民稱
myThreadDemo1.setName("tom");
myThreadDemo2.setName("jack");
myThreadDemo1.run();
myThreadDemo2.run();*/
/* // 創(chuàng)建對(duì)象
MyThreadDemo myThreadDemo1 = new MyThreadDemo("tom");
MyThreadDemo myThreadDemo2 = new MyThreadDemo("jack");
myThreadDemo1.run();
myThreadDemo2.run();*/
//我要獲取main方法所在的線程對(duì)象的名稱，該怎么辦呢?
//遇到這種情況,Thread類提供了一個(gè)很好玩的方法:
//public static Thread currentThread():返回當(dāng)前正在執(zhí)行的線程對(duì)象
System.out.println(Thread.currentThread().getName());
}
}
/*
名稱為什么是：Thread-? 編號(hào)
class Thread {
private char name[];
public Thread() {
init(null, null, "Thread-" + nextThreadNum(), 0);
}
private void init(ThreadGroup g, Runnable target, String name,
long stackSize) {
init(g, target, name, stackSize, null);
}
private void init(ThreadGroup g, Runnable target, String name,
long stackSize, AccessControlContext acc) {
//大部分代碼被省略了
this.name = name.toCharArray();
}
public final void setName(String name) {
this.name = name.toCharArray();
}
private static int threadInitNumber; //0,1,2
private static synchronized int nextThreadNum() {
return threadInitNumber++; //return 0,1
}
public final String getName() {
return String.valueOf(name);
}
}
class MyThread extends Thread {
public MyThread() {
super();
}
}
*/
方式二
package com.toltech.springboot.test;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27
*/
public class MyRunnable implements Runnable {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
// 由于實(shí)現(xiàn)接口的方式就不能直接使用Thread類的方法了,但是可以間接的使用
System.out.println(Thread.currentThread().getName() + ":" + x);
}
}
}
/*
* 方式2：實(shí)現(xiàn)Runnable接口
* 步驟：
* A:自定義類MyRunnable實(shí)現(xiàn)Runnable接口
* B:重寫run()方法
* C:創(chuàng)建MyRunnable類的對(duì)象
* D:創(chuàng)建Thread類的對(duì)象，并把C步驟的對(duì)象作為構(gòu)造參數(shù)傳遞
*/
class MyRunnableDemo {
public static void main(String[] args) {
// 創(chuàng)建MyRunnable類的對(duì)象
MyRunnable my = new MyRunnable();
// 創(chuàng)建Thread類的對(duì)象，并把C步驟的對(duì)象作為構(gòu)造參數(shù)傳遞
// Thread(Runnable target)
// Thread t1 = new Thread(my);
// Thread t2 = new Thread(my);
// t1.setName("林青霞");
// t2.setName("劉意");
// Thread(Runnable target, String name)
Thread t1 = new Thread(my, "林青霞");
Thread t2 = new Thread(my, "劉意");
t1.start();
t2.start();
}
}
應(yīng)用
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
//給用戶發(fā)送激活郵件
String uuid = UUID.randomUUID().toString();
String url = "http://localhost/user/active?_="+uuid;
// String url = "http://bbs.kaishengit.com/user/active?_="+uuid;
//放入緩存等待6個(gè)小時(shí)
cache.put(uuid,username);
String html ="<h3>Dear "+username+":</h3>請(qǐng)點(diǎn)擊<a href='"+url+"'>該鏈接</a>去激活你的賬號(hào). <br> 凱盛軟件";
EmailUtil.sendHtmlEmail(email,"用戶激活郵件",html);
}
});
thread.start();
線程池創(chuàng)建
JDK5新增了一個(gè)Executors工廠類來產(chǎn)生線程池，有如下幾個(gè)方法
public static ExecutorService newCachedThreadPool()
public static ExecutorService newFixedThreadPool(int nThreads)
public static ExecutorService newSingleThreadExecutor()
這些方法的返回值是ExecutorService對(duì)象，該對(duì)象表示一個(gè)線程池，可以執(zhí)行Runnable對(duì)象或者Callable對(duì)象代表的線程。它提供了如下方法
Future<?> submit(Runnable task)
<T> Future<T> submit(Callable<T> task)
案例演示
創(chuàng)建線程池對(duì)象
創(chuàng)建Runnable實(shí)例
提交Runnable實(shí)例
關(guān)閉線程池
package com.toltech.springboot.test;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27
*/
class MyRunnables implements Runnable {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println(Thread.currentThread().getName() + ":" + x);
}
}
}
/*
* 線程池的好處：線程池里的每一個(gè)線程代碼結(jié)束后，并不會(huì)死亡，而是再次回到線程池中成為空閑狀態(tài)，等待下一個(gè)對(duì)象來使用。
*
* 如何實(shí)現(xiàn)線程的代碼呢?
* A:創(chuàng)建一個(gè)線程池對(duì)象，控制要?jiǎng)?chuàng)建幾個(gè)線程對(duì)象。
* public static ExecutorService newFixedThreadPool(int nThreads)
* B:這種線程池的線程可以執(zhí)行：
* 可以執(zhí)行Runnable對(duì)象或者Callable對(duì)象代表的線程
* 做一個(gè)類實(shí)現(xiàn)Runnable接口。
* C:調(diào)用如下方法即可
* Future<?> submit(Runnable task)
* <T> Future<T> submit(Callable<T> task)
* D:我就要結(jié)束，可以嗎?
* 可以。
*/
public class ExecutorsDemo {
public static void main(String[] args) {
// 創(chuàng)建一個(gè)線程池對(duì)象，控制要?jiǎng)?chuàng)建幾個(gè)線程對(duì)象。
// public static ExecutorService newFixedThreadPool(int nThreads)
ExecutorService pool = Executors.newFixedThreadPool(2);
// 可以執(zhí)行Runnable對(duì)象或者Callable對(duì)象代表的線程
pool.submit(new MyRunnables());
pool.submit(new MyRunnables());
//結(jié)束線程池
pool.shutdown();
}
}
睡眠
package com.toltech.springboot.test;
import java.util.Date;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27
*/
public class ThreadSleep extends Thread {
@Override
public void run() {
for (int i = 0; i <= 100; i++) {
System.out.println(getName() + ": " + i + new Date());
// 睡眠 一秒鐘
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Test{
public static void main(String[] args) {
ThreadSleep threadSleep = new ThreadSleep();
ThreadSleep threadSleep1 = new ThreadSleep();
threadSleep.setName("tom");
threadSleep1.setName("jack");
threadSleep.run();
threadSleep1.run();
}
}
守護(hù)線程
package com.toltech.springboot.test;
class ThreadDaemon extends Thread {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println(getName() + ":" + x);
}
}
}
/*
* public final void setDaemon(boolean on):將該線程標(biāo)記為守護(hù)線程或用戶線程。
* 當(dāng)正在運(yùn)行的線程都是守護(hù)線程時(shí)，Java 虛擬機(jī)退出。 該方法必須在啟動(dòng)線程前調(diào)用。
*
* 游戲：坦克大戰(zhàn)。
*/
public class ThreadDaemonDemo {
public static void main(String[] args) {
ThreadDaemon td1 = new ThreadDaemon();
ThreadDaemon td2 = new ThreadDaemon();
td1.setName("關(guān)羽");
td2.setName("張飛");
// 設(shè)置收獲線程
td1.setDaemon(true);
td2.setDaemon(true);
td1.start();
td2.start();
Thread.currentThread().setName("劉備");
for (int x = 0; x < 5; x++) {
System.out.println(Thread.currentThread().getName() + ":" + x);
}
}
}
加入線程
package com.toltech.springboot.test;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27
*/
public class ThreadJoin extends Thread {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println(getName() + ":" + x);
}
}
}
/*
* public final void join():等待該線程終止。
*/
class ThreadJoinDemo {
public static void main(String[] args) {
ThreadJoin tj1 = new ThreadJoin();
ThreadJoin tj2 = new ThreadJoin();
ThreadJoin tj3 = new ThreadJoin();
tj1.setName("李淵");
tj2.setName("李世民");
tj3.setName("李元霸");
tj1.start();
try {
// 執(zhí)行完后 tj2 tj3 在執(zhí)行
tj1.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
tj2.start();
tj3.start();
}
}
優(yōu)先級(jí)
package com.toltech.springboot.test;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27
*/
public class ThreadPriority extends Thread {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println(getName() + ":" + x);
}
}
}
/*
* 我們的線程沒有設(shè)置優(yōu)先級(jí),肯定有默認(rèn)優(yōu)先級(jí)。
* 那么，默認(rèn)優(yōu)先級(jí)是多少呢?
* 如何獲取線程對(duì)象的優(yōu)先級(jí)?
* public final int getPriority():返回線程對(duì)象的優(yōu)先級(jí)
* 如何設(shè)置線程對(duì)象的優(yōu)先級(jí)呢?
* public final void setPriority(int newPriority)：更改線程的優(yōu)先級(jí)。
*
* 注意：
* 線程默認(rèn)優(yōu)先級(jí)是5。
* 線程優(yōu)先級(jí)的范圍是：1-10。
* 線程優(yōu)先級(jí)高僅僅表示線程獲取的 CPU時(shí)間片的幾率高，但是要在次數(shù)比較多，或者多次運(yùn)行的時(shí)候才能看到比較好的效果。
*
* IllegalArgumentException:非法參數(shù)異常。
* 拋出的異常表明向方法傳遞了一個(gè)不合法或不正確的參數(shù)。
*
*/
class ThreadPriorityDemo {
public static void main(String[] args) {
ThreadPriority tp1 = new ThreadPriority();
ThreadPriority tp2 = new ThreadPriority();
ThreadPriority tp3 = new ThreadPriority();
tp1.setName("東方不敗");
tp2.setName("岳不群");
tp3.setName("林平之");
// 獲取默認(rèn)優(yōu)先級(jí)
// System.out.println(tp1.getPriority());
// System.out.println(tp2.getPriority());
// System.out.println(tp3.getPriority());
// 設(shè)置線程優(yōu)先級(jí)
// tp1.setPriority(100000);
//設(shè)置正確的線程優(yōu)先級(jí)
tp1.setPriority(10);
tp2.setPriority(1);
tp1.start();
tp2.start();
tp3.start();
}
}
終止線程
package com.toltech.springboot.test;
import java.util.Date;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27
*/
public class ThreadStop extends Thread {
@Override
public void run() {
System.out.println("開始執(zhí)行：" + new Date());
// 我要休息10秒鐘，親，不要打擾我哦
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
// e.printStackTrace();
System.out.println("線程被終止了");
}
System.out.println("結(jié)束執(zhí)行：" + new Date());
}
}
/*
* public final void stop():讓線程停止，過時(shí)了，但是還可以使用。
* public void interrupt():中斷線程。 把線程的狀態(tài)終止，并拋出一個(gè)InterruptedException。
*/
class ThreadStopDemo {
public static void main(String[] args) {
ThreadStop ts = new ThreadStop();
ts.start();
// 你超過三秒不醒過來，我就干死你
try {
Thread.sleep(3000);
// ts.stop();
ts.interrupt();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
暫停線程
package com.toltech.springboot.test;
/**
* @author Wgs
* @version 1.0
* @create：2017/11/27
*/
public class ThreadYield extends Thread {
@Override
public void run() {
for (int x = 0; x < 100; x++) {
System.out.println(getName() + ":" + x);
Thread.yield();
}
}
}
/*
* public static void yield():暫停當(dāng)前正在執(zhí)行的線程對(duì)象，并執(zhí)行其他線程。
* 讓多個(gè)線程的執(zhí)行更和諧，但是不能靠它保證一人一次。
*/
class ThreadYieldDemo {
public static void main(String[] args) {
ThreadYield ty1 = new ThreadYield();
ThreadYield ty2 = new ThreadYield();
ty1.setName("林青霞");
ty2.setName("劉意");
ty1.start();
ty2.start();
}
}
