开启线程
线程的开启方式主要有四种:
1、new一个Thread对象,start方法后,执行线程内容
Thread thread = new Thread() {
@Override
public void run() {
super.run();
for (int i = 0; i < 5; i++) {
System.out.println("打印Thread数据" + i);
}
}
};
thread.start();
2、实现Runnalbe接口的类
class typeRun implements Runnable {
@Override
public void run() {
for (int i = 0; i < 6; i++) {
System.out.println("打印Runnable数据" + i);
}
}
}
typeRun typeRun = new typeRun();
Thread thread = new Thread(typeRun);
thread.start();
3、通过线程池处理线程;需要注意的是线程池的核心类是ThreadPoolExecutor,其中参数corePoolSize是核心线程数量,maximumPoolSize最大线程数量,keepAliveTime存活时间,unit存活时间单位,workQueue是存放线程的队列;其中常用的四种线程池方法分别是newCachedThreadPool(),newFixedThreadPool(2),newSingleThreadExecutor(),newScheduledThreadPool(2)
ExecutorService service = Executors.newCachedThreadPool();
service.execute(new Runnable() {
@Override
public void run() {
for (int i = 0; i < 6; i++) {
System.out.println("打印newFixedThreadPool数据" + i);
}
}
});
关键字同步 synchronized volatile AtomicInteger
synchronized 用来同步代码块,同步的内容即锁住对象,类的共享资源,防止多线程中的一个线程写操作执行一般时,其他线程参与导致共享资源数据出现错误
volatile是简化版同步字段,用来锁定变量同步,但是不能保证非原子性操作内容
AtomicInteger 用来自增加相关数据,已含有同步功能
关键字线程间通信 stop interrupt wait notify notifyAll
stop是直接关闭线程,由于不能通知让线程做相关操作,已被废弃
interrupt用于告诉线程中断操作,线程内可以根据isInterrupted()判断中断线程后可以做某些操作;Thread.interrupted()和sleep()异常InterruptedException拿到中断通知后改变中断变量isInterrupted()方法有true改为false
private static void threadInteraction() {
Thread thread = new Thread() {
@Override
public void run() {
super.run();
for (int i = 0; i < 100000; i++) {
// System.out.println("打印newFixedThreadPool数据" + isInterrupted());
// if (Thread.interrupted()) { //该方法获取终端状态且修改状态,打印出false
if (isInterrupted()) { //该方法只做判断,不修改是否终端状态,打印出true
System.out.println("interrupt==" + isInterrupted());
return;
}
System.out.println("打印newFixedThreadPool数据" + i + "///" + isInterrupted());
// }
}
}
};
thread.start();
try {
Thread.sleep(20);
} catch ( InterruptedException e) { //捕获到终端异常,则修改中断状态
e.printStackTrace();
}
// thread.stop(); //已废弃的方法
thread.interrupt();
wait、notify和notifyAll 用于同步代码块内,wait伙同while 判断某种情况是否需要等待其他操作完成后再进行下一步的操作,而notifyAll则用来初始化完成后通知wait 继续下面的操作
private static String content;
private synchronized void initContent() {
content = "初始化了啊";
notifyAll(); //初始化后,通知其他线程可以获取初始值了
}
private synchronized String getContent() {
//注意和synchronized while搭配使用
while (content == null) {
try {
wait(); //当获取初始化了值的,如果没有初始化,则等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return content;
}