在Java中,关于线程的同步
2015-10-10 10:56
288 查看
线程同步的方式一:同步代码块
代码示例一如下:
代码示例二如下:
线程同步的方式二:同步方法
代码示例如下:
package com.atguigu.java;
//使用实现Runnable接口的方式,售票
/*
* 此程序存在线程的安全问题:打印车票时,会出现重票、错票
* 1.线程安全问题存在的原因?
* 由于一个线程在操作共享数据过程中,未执行完毕的情况下,另外的线程参与进来,导致共享数据存在了安全问题。
*
* 2.如何来解决线程的安全问题?
* 必须让一个线程操作共享数据完毕以后,其它线程才有机会参与共享数据的操作。
*
* 3.java如何实现线程的安全:线程的同步机制
*
* 方式一:同步代码块
* synchronized(同步监视器){
* //需要被同步的代码块(即为操作共享数据的代码)
* }
* 1.共享数据:多个线程共同操作的同一个数据(变量)
* 2.同步监视器:由一个类的对象来充当。哪个线程获取此监视器,谁就执行大括号里被同步的代码。俗称:锁
* 要求:所有的线程必须共用同一把锁!
* 注:在实现的方式中,考虑同步的话,可以使用this来充当锁。但是在继承的方式中,慎用this!
*
* 方式二:同步方法
* 将操作共享数据的方法声明为synchronized。即此方法为同步方法,能够保证当其中一个线程执行
* 此方法时,其它线程在外等待直至此线程执行完此方法。
* >同步方法的锁:this
*
* 4.线程的同步的弊端:由于同一个时间只能有一个线程访问共享数据,效率变低了。
*
*/
class Window4 implements Runnable {
int ticket = 100;// 共享数据
public void run() {
while (true) {
show();
}
}
public synchronized void show() {
if (ticket > 0) {
try {
Thread.currentThread().sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "售票,票号为:"
+ ticket--);
}
}
}
public class TestWindow4 {
public static void main(String[] args) {
Window4 w = new Window4();
Thread t1 = new Thread(w);
Thread t2 = new Thread(w);
Thread t3 = new Thread(w);
t1.setName("窗口1");
t2.setName("窗口2");
t3.setName("窗口3");
t1.start();
t2.start();
t3.start();
}
}
注:关于死锁
死锁:不同的线程分别占用对方需要的同步资源不放弃,都在等待对方放弃自己需要的同步资源,就形成了线程的死锁
代码示例一如下:
package com.atguigu.java; //使用实现Runnable接口的方式,售票 /* * 此程序存在线程的安全问题:打印车票时,会出现重票、错票 * 1.线程安全问题存在的原因? * 由于一个线程在操作共享数据过程中,未执行完毕的情况下,另外的线程参与进来,导致共享数据存在了安全问题。 * * 2.如何来解决线程的安全问题? * 必须让一个线程操作共享数据完毕以后,其它线程才有机会参与共享数据的操作。 * * 3.java如何实现线程的安全:线程的同步机制 * * 方式一:同步代码块 * synchronized(同步监视器){ * //需要被同步的代码块(即为操作共享数据的代码) * } * 1.共享数据:多个线程共同操作的同一个数据(变量) * 2.同步监视器:可由任意一个类的对象来充当。哪个线程获取此监视器,谁就执行大括号里被同步的代码。俗称:锁 * 要求:所有的线程必须共用同一把锁! * 注:在实现的方式中,考虑同步的话,可以使用this来充当锁。但是在继承的方式中,慎用this! * * 方式二:同步方法 * * */ class Window2 implements Runnable { int ticket = 100;// 共享数据 // Object obj = new Object(); public void run() { // Animal a = new Animal();//局部变量,用这种局部变量当做锁是错误,因为每个线程进来,都会new一把锁; //所以我们始终需要铭记一点,锁必须确保只有一把; //若要使用,需哟将其声明在fun()方法外,Window2类内;例如Object obj = new Object()的位置; while (true) { synchronized (this) {//this表示当前对象,本题中即为w,关于this的使用,具体问题具体分析;当然在这里也可以用obj对象; if (ticket > 0) { try { Thread.currentThread().sleep(10); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "售票,票号为:" + ticket--); } } } } } public class TestWindow2 { public static void main(String[] args) { Window2 w = new Window2(); Thread t1 = new Thread(w); Thread t2 = new Thread(w); Thread t3 = new Thread(w); t1.setName("窗口1"); t2.setName("窗口2"); t3.setName("窗口3"); t1.start(); t2.start(); t3.start(); } } class Animal{ }
代码示例二如下:
package com.atguigu.java; //模拟火车站售票窗口,开启三个窗口售票,总票数为100张 //存在线程的安全问题--->使用同步代码块处理。 class Window3 extends Thread { static int ticket = 100; static Object obj = new Object(); public void run() { while (true) { // synchronized (this) {//在本问题中,this表示:w1,w2,w3 synchronized (obj) { // show(); //在本例中,由于同步方法的锁是this对象,而this对象在本例中,对应有三个:w1,w2,w3;所以没法使用同步方法; if (ticket > 0) { //只能用同步代码块; try { Thread.currentThread().sleep(10); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "售票,票号为:" + ticket--); } } } } public synchronized void show() {// this充当的锁 if (ticket > 0) { try { Thread.currentThread().sleep(10); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "售票,票号为:" + ticket--); } } } public class TestWindow3 { public static void main(String[] args) { Window3 w1 = new Window3(); Window3 w2 = new Window3(); Window3 w3 = new Window3(); w1.setName("窗口1"); w2.setName("窗口2"); w3.setName("窗口3"); w1.start(); w2.start(); w3.start(); } }
线程同步的方式二:同步方法
代码示例如下:
package com.atguigu.java;
//使用实现Runnable接口的方式,售票
/*
* 此程序存在线程的安全问题:打印车票时,会出现重票、错票
* 1.线程安全问题存在的原因?
* 由于一个线程在操作共享数据过程中,未执行完毕的情况下,另外的线程参与进来,导致共享数据存在了安全问题。
*
* 2.如何来解决线程的安全问题?
* 必须让一个线程操作共享数据完毕以后,其它线程才有机会参与共享数据的操作。
*
* 3.java如何实现线程的安全:线程的同步机制
*
* 方式一:同步代码块
* synchronized(同步监视器){
* //需要被同步的代码块(即为操作共享数据的代码)
* }
* 1.共享数据:多个线程共同操作的同一个数据(变量)
* 2.同步监视器:由一个类的对象来充当。哪个线程获取此监视器,谁就执行大括号里被同步的代码。俗称:锁
* 要求:所有的线程必须共用同一把锁!
* 注:在实现的方式中,考虑同步的话,可以使用this来充当锁。但是在继承的方式中,慎用this!
*
* 方式二:同步方法
* 将操作共享数据的方法声明为synchronized。即此方法为同步方法,能够保证当其中一个线程执行
* 此方法时,其它线程在外等待直至此线程执行完此方法。
* >同步方法的锁:this
*
* 4.线程的同步的弊端:由于同一个时间只能有一个线程访问共享数据,效率变低了。
*
*/
class Window4 implements Runnable {
int ticket = 100;// 共享数据
public void run() {
while (true) {
show();
}
}
public synchronized void show() {
if (ticket > 0) {
try {
Thread.currentThread().sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "售票,票号为:"
+ ticket--);
}
}
}
public class TestWindow4 {
public static void main(String[] args) {
Window4 w = new Window4();
Thread t1 = new Thread(w);
Thread t2 = new Thread(w);
Thread t3 = new Thread(w);
t1.setName("窗口1");
t2.setName("窗口2");
t3.setName("窗口3");
t1.start();
t2.start();
t3.start();
}
}
注:关于死锁
死锁:不同的线程分别占用对方需要的同步资源不放弃,都在等待对方放弃自己需要的同步资源,就形成了线程的死锁
相关文章推荐
- 在Java中,关于线程的创建,方法及生命周期
- java集合的体系
- Java的JUnit
- Java的包装类,基本数据类型和String类之间的转化
- 在eclipse下如何查找某一个类的源码
- Java中this与super,构造器执行顺序
- Eclipse常用快捷键
- Java的foreach语句
- 关于Java的JNI
- java使用.net的webservice
- 关于Java的多态
- Java彩信接口开发经验及具体开发实现
- java反射机制学习
- Struts2版本引起的问题
- java中时间比较
- java 基础第一季
- 处理myeclipse编辑jsp卡的问题
- java.lang.IllegalStateException: The remote endpoint was in state [TEXT_FULL_WRITING] which is an invalid state for called method 解决办法
- struts配置问题
- Java线程的wait() 与notify()