线程同步与死锁

线程同步与死锁

课程大纲

一、 多线程共享数据

1、在多线程的操作中，多个线程有可能同时处理同一个资源，这就是多线程中的共享数据。

二、 线程同步

1、 解决数据共享问题，必须使用同步，所谓同步就是指多个线程在同一个时刻只能有一个线程执行指定代码，其他线程要等到该线程执行结束之后才能继续执行。

2、 线程同步有两种方法

（1）、同步代码块synchronized（要同步的对象）

{

要同步的操作

}

（2）、同步方法

Public synchronize void method()

{

要同步的操作

}

三、 同步准则

1、 当编写synchronize块时，有几个简单的准则可以遵循，这些准则在避免死锁和性能危险的风险方面大有帮助：

2、 （1）、使代码块简短，把不随线程变化的预处理和后处理移出synchronize块。

3、 （2）、不要阻塞，如：InputStream.Read()

4、 （3）、在持有锁的时候，不要对其他对象调用方法。

四、 线程死锁

1、过多的同步有可能出现死锁，死锁的操作一般是在程序运行的时候才有可能出现。

代码如下：

package us.google;

/**

* 多线程共享数据的安全问题。使用同步解决

* 1、同步代码块

* 2、同步方法

* 同步代码会代来性能降低的问题，提高数据的安全性。

* @author chongrubujing

*

*/

public class ThreadDemo {

public static void main(String[] args) {
Mythread my = new Mythread();
Thread t1 = new Thread(my,"小白");
Thread t2 = new Thread(my,"小黑");
t1.start();//启动的时候就会调用run方法
t2.start();

}

}

class Mythread implements Runnable

{

@Override
public void run() {
/*//方法一：同步代码块
synchronized (this) {//括号总可以写任意对象
System.out.println(Thread.currentThread().getName()+"正在吃饭");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"吃饭了");*/
//调用method方法
method();
}

//方法二：同步方法，同步的是当前对象（this）
public synchronized void method()
{
System.out.println(Thread.currentThread().getName()+"正在吃饭");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"吃饭了");
}

}

死锁：是有几率的

package us.google;

/**

* 线程死锁

* @author chongrubujing

*

*/

public class DeadThreadDemo {

public static void main(String[] args) {
new DeadThread();//new的时候先调用构造方法，构造方法中start时候再调用run（）方法，run（）方法
//最后调用
}

}

//顾客

class Customer

{

public synchronized void say(Waiter w)

{

System.out.println(“顾客说先做再给钱！”);

w.doService();

}

public synchronized void doService()

{

System.out.println(“同意了，先给钱再做”);

}

}

//服务员

class Waiter

{

public synchronized void say(Customer c)

{

System.out.println(“服务员说：先给钱再做！”);

c.doService();

}

public synchronized void doService()

{

System.out.println(“同意了，先做再给钱！”);

}

}

//死锁线程

class DeadThread implements Runnable

{

Customer c = new Customer();
Waiter w = new Waiter();
//无参构造方法
public DeadThread() {
new Thread(this).start();//this代表的是DeadThread的一个对象
w.say(c);
}
@Override
public void run() {
c.say(w);
}

}