多线程编程模板
1、线程 操作 资源类 2、高内聚、低耦合
创建线程的四种方式
继承Thread创建线程(非常不推荐)
run()为线程类的核心方法,相当于主线程的main方法,是每个线程的入口 具体案例如下
public class MyThread extends Thread {
public MyThread() {
}
public void run() {
for(int i=0;i<10;i++) {
System.out.println(Thread.currentThread()+":"+i);
}
}
public static void main(String[] args) {
MyThread mThread1=new MyThread();
MyThread mThread2=new MyThread();
MyThread myThread3=new MyThread();
mThread1.start();
mThread2.start();
myThread3.start();
}
}
Runnable接口(推荐)
a.覆写Runnable接口实现多线程可以避免单继承局限 b.当子类实现Runnable接口,此时子类和Thread的代理模式(子类负责真是业务的操作,thread负责资源调度与线程创建辅助真实业务。
实现
class MyThreadimplementsRunnable//新建类实现runnable接口
new Thread(newMyThread,...)
这种方法会新增类,有更新更好的方法
public class MyThread implements Runnable{
public static int count=20;
public void run() {
while(count>0) {
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"-当前剩余票数:"+count--);
}
}
public static void main(String[] args) {
MyThread Thread1=new MyThread();
Thread mThread1=new Thread(Thread1,"线程1");
Thread mThread2=new Thread(Thread1,"线程2");
Thread mThread3=new Thread(Thread1,"线程3");
mThread1.start();
mThread2.start();
myThread3.start();
}
new Thread(new Runnable() {
@Override
publicvoid run() {
}
}, "your thread name").start();
这种方法不需要创建新的类,可以new接口
还有复写Callable接口和使用线程池的方法,后面会详细讲解。
Lambda表达式
Lambda 表达式,也可称为闭包,它是推动 Java 8 发布的最重要新特性。 Lambda 允许把函数作为一个方法的参数(函数作为参数传递进方法中)。 使用 Lambda 表达式可以使代码变的更加简洁紧凑。
语法
lambda 表达式的语法格式如下: (parameters) -> expression 或 (parameters) ->{statements; } 案例
// 1. 不需要参数,返回值为 5
() -> 5
// 2. 接收一个参数(数字类型),返回其2倍的值
x -> 2 * x
// 3. 接受2个参数(数字),并返回他们的差值
(x, y) -> x – y
// 4. 接收2个int型整数,返回他们的和
(int x, int y) -> x + y
// 5. 接受一个 string 对象,并在控制台打印,不返回任何值(看起来像是返回void)
(String s) -> System.out.print(s)
使用lambda表达式可以这样创建线程
new Thread(() -> {
}, "your thread name").start();
这种方法代码更简洁精炼
Synchronized同步代码块
synchronized 的作用主要有三:
- (1)、原子性:**所谓原子性就是指一个操作或者多个操作,要么全部执行并且执行的过程不会被任何因素打断,要么就都不执行。**被synchronized修饰的类或对象的所有操作都是原子的,因为在执行操作之前必须先获得类或对象的锁,直到执行完才能释放。
- (2)、可见性:**可见性是指多个线程访问一个资源时,该资源的状态、值信息等对于其他线程都是可见的。 **synchronized和volatile都具有可见性,其中synchronized对一个类或对象加锁时,一个线程如果要访问该类或对象必须先获得它的锁,而这个锁的状态对于其他任何线程都是可见的,并且在释放锁之前会将对变量的修改刷新到共享内存当中,保证资源变量的可见性。
- (3)、有序性:有序性值程序执行的顺序按照代码先后执行。 synchronized和volatile都具有有序性,Java允许编译器和处理器对指令进行重排,但是指令重排并不会影响单线程的顺序,它影响的是多线程并发执行的顺序性。synchronized保证了每个时刻都只有一个线程访问同步代码块,也就确定了线程执行同步代码块是分先后顺序的,保证了有序性。
卖票例子
public class ThreadSynchronizationTest {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
TicketSeller seller = new TicketSeller();
Thread t1 = new Thread(seller);
Thread t2 = new Thread(seller);
Thread t3 = new Thread(seller);
t1.start();
t2.start();
t3.start();
}
}
/**
*
* @author Administrator
*
*/
class TicketSeller implements Runnable{
int ticket_num = 100;
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
synchronized(this){
if(ticket_num > 0){
try{
Thread.sleep((int)Math.random()*2000);
}catch(Exception e){
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + " is sell the ticket " + ticket_num);
ticket_num --;
}
}
}
}
}
Lock接口锁
什么是可重入锁
通俗来说:当线程请求一个由其它线程持有的对象锁时,该线程会阻塞,而当线程请求由自己持有的对象锁时,如果该锁是重入锁,请求就会成功,否则阻塞。 锁实现提供了比使用同步方法和语句可以获得的更广泛的锁操作。它们允许更灵活的结构,可能具有非常不同的属性,并且可能支持多个关联的条件对象。
实现lock的常见类:
ReentrantLock:表示重入锁,它是唯一一个实现了 Lock 接口的类 ReentrantReadWriteLock:重入读写锁,在这个类中维护了两个锁,一个是 ReadLock,一个是 WriteLock,他们都分别实现了 Lock接口。读写锁是一种适合读多写少的场景,基本原则是: 读和读不互斥、读和写互斥、写和写互斥。
class X {
private final ReentrantLock lock = new ReentrantLock();
// ...
public void m() {
lock.lock(); // block until condition holds
try {
// ... method body
} finally {
lock.unlock()
}
}
}
synchronized与Lock的区别
两者区别: 1.首先synchronized是java内置关键字,在jvm层面,Lock是个java类; 2.synchronized无法判断是否获取锁的状态,Lock可以判断是否获取到锁; 3.synchronized会自动释放锁(a 线程执行完同步代码会释放锁 ;b 线程执行过程中发生异常会释放锁),Lock需在finally中手工释放锁(unlock()方法释放锁),否则容易造成线程死锁; 4.用synchronized关键字的两个线程1和线程2,如果当前线程1获得锁,线程2线程等待。如果线程1阻塞,线程2则会一直等待下去,而Lock锁就不一定会等待下去,如果尝试获取不到锁,线程可以不用一直等待就结束了; 5.synchronized的锁可重入、不可中断、非公平,而Lock锁可重入、可判断、可公平(两者皆可) 6.Lock锁适合大量同步的代码的同步问题,synchronized锁适合代码少量的同步问题。
0 Comments
Leave a comment