当前位置:首页 » 编程语言 » java同步多线程

java同步多线程

发布时间: 2023-09-08 08:50:45

java多线程调用同步方法时,休眠后代码为什么执行不到

1、型正java多线程调用同步方法时主程序或者后台服务Service程猜租答序两者必须有一个正在运行着,定时任务才会执行。
2、自动穗慧执行的任务可以设置开启或关闭定时,检查任务的这一开关处于开启状态。
3、源目录在定时的时间点如果没有变化,任务执行后不会留下日志,通过查看任务的最后执行时间确定任务到底执行了没有。
4、执行失败和没有执行不是同一回事,如果是执行失败则要分析失败原因。这是java多线程调用同步方法时,休眠后代码执行不到的原因。

⑵ Java多线程初学者指南(10):使用Synchronized关键字同步类方法

要想解决 脏数据 的问题 最简单的方法就是使用synchronized关键字来使run方法同步 代码如下

publicsynchronizedvoidrun(){}

从上面的代码可以看出 只要在void和public之间加上synchronized关键字 就可以使run方法同步 也就是说 对于同一个Java类的对象实例 run方法同时只能被一个线程调用 并当前的run执行完后 才能被其他的线程调用 即使当前线程执行到了run方法中的yield方法 也只是暂停了一下 由于其他线程无法执行run方法 因此 最终还是会由当前的线程来继续执行 先看看下面的代码

sychronized关键字只和一个对象实例绑定

classTest{publicsynchronizedvoidmethod(){}纳察}{privateTesttest;publicvoidrun() { thod(); } publicSync(Testtest) { this test=test; } publicstaticvoidmain(String[]args)throwsException { Testtest =newTest(); Testtest =newTest(); Syncsync =newSync(test ); Syncsync =newSync(test ); newThread(sync ) start(); newThread(sync ) start(); } }

在Test类中的method方法是同步的 但上面的代码建立了两个Test类的实例 因此 test 和test 的method方法是分别执行的 要想让method同步 必须在建立仿茄升Sync类的实例时向它的构造方法中传入同一个Test类的实例 如下面的代码所示

Syncsync =newSync(test );

不仅可以使用synchronized来同步非静态方法 也可以使用synchronized来同步静态方法 如可以按如下方式来定义method方法

classTest{ (){}}

建立Test类的对象实例如下

Testtest=newTest();

对于静态方法来说 只要加上了synchronized关键字 这个方法就是同步的 无论是使用thod() 还是使用thod()来调用method方法 method都是同步的 并不存在非静态方法的多个实例的问题

在 种设计模式中的单件(Singleton)模式如果按传统的方法设计 也是线程不安全的 下面的代码是一个线程不安全的单件模式

packagetest;//线程安全的Singleton模式classSingleton{privatestaticSingletonsample;privateSingleton(){备老}(){if(sample==null){Thread yield();//为了放大Singleton模式的线程不安全性sample=newSingleton();}returnsample;}}{publicvoidrun(){Singletonsingleton=Singleton getInstance();System out println(singleton hashCode());}publicstaticvoidmain(String[]args){Threadthreads[]=newThread[ ];for(inti= ;i<threads length;i++)threads[i]=newMyThread();for(inti= ;i<threads length;i++)threads[i] start();}}

在上面的代码调用yield方法是为了使单件模式的线程不安全性表现出来 如果将这行去掉 上面的实现仍然是线程不安全的 只是出现的可能性小得多

程序的运行结果如下

上面的运行结果可能在不同的运行环境上有所有同 但一般这五行输出不会完全相同 从这个输出结果可以看出 通过getInstance方法得到的对象实例是五个 而不是我们期望的一个 这是因为当一个线程执行了Thread yield()后 就将CPU资源交给了另外一个线程 由于在线程之间切换时并未执行到创建Singleton对象实例的语句 因此 这几个线程都通过了if判断 所以 就会产生了建立五个对象实例的情况(可能创建的是四个或三个对象实例 这取决于有多少个线程在创建Singleton对象之前通过了if判断 每次运行时可能结果会不一样)

要想使上面的单件模式变成线程安全的 只要为getInstance加上synchronized关键字即可 代码如下

(){}

当然 还有更简单的方法 就是在定义Singleton变量时就建立Singleton对象 代码如下

=newSingleton();

然后在getInstance方法中直接将sample返回即可 这种方式虽然简单 但不知在getInstance方法中创建Singleton对象灵活 读者可以根据具体的需求选择使用不同的方法来实现单件模式

在使用synchronized关键字时有以下四点需要注意

synchronized关键字不能继承

虽然可以使用synchronized来定义方法 但synchronized并不属于方法定义的一部分 因此 synchronized关键字不能被继承 如果在父类中的某个方法使用了synchronized关键字 而在子类中覆盖了这个方法 在子类中的这个方法默认情况下并不是同步的 而必须显式地在子类的这个方法中加上synchronized关键字才可以 当然 还可以在子类方法中调用父类中相应的方法 这样虽然子类中的方法不是同步的 但子类调用了父类的同步方法 因此 子类的方法也就相当于同步了 这两种方式的例子代码如下

在子类方法中加上synchronized关键字

classParent{ publicsynchronizedvoidmethod(){}}classChildextendsParent{ publicsynchronizedvoidmethod(){}}

在子类方法中调用父类的同步方法

classParent{ publicsynchronizedvoidmethod(){}}classChildextendsParent{publicvoidmethod(){thod();}}

在定义接口方法时不能使用synchronized关键字

构造方法不能使用synchronized关键字 但可以使用下节要讨论的synchronized块来进行同步

synchronized可以自由放置

在前面的例子中使用都是将synchronized关键字放在方法的返回类型前面 但这并不是synchronized可放置唯一位置 在非静态方法中 synchronized还可以放在方法定义的最前面 在静态方法中 synchronized可以放在static的前面 代码如下

publicsynchronizedvoidmethod();synchronizedpublicvoidmethod();();();();

但要注意 synchronized不能放在方法返回类型的后面 如下面的代码是错误的

publicvoidsynchronizedmethod();();

synchronized关键字只能用来同步方法 不能用来同步类变量 如下面的代码也是错误的

publicsynchronizedintn= ;publicstaticsynchronizedintn= ;

虽然使用synchronized关键字同步方法是最安全的同步方式 但大量使用synchronized关键字会造成不必要的资源消耗以及性能损失 虽然从表面上看synchronized锁定的是一个方法 但实际上synchronized锁定的是一个类 也就是说 如果在非静态方法method 和method 定义时都使用了synchronized 在method 未执行完之前 method 是不能执行的 静态方法和非静态方法的情况类似 但静态和非静态方法不会互相影响 看看如下的代码

packagetest;publicclassMyThread extendsThread{publicStringmethodName;publicstaticvoidmethod(Strings){System out println(s);while(true);}publicsynchronizedvoidmethod (){method( 非静态的method 方法 );}publicsynchronizedvoidmethod (){method( 非静态的method 方法 );} (){method( 静态的method 方法 );} (){method( 静态的method 方法 );}publicvoidrun(){try{getClass() getMethod(methodName) invoke(this);}catch(Exceptione){}}publicstaticvoidmain(String[]args)throwsException{MyThread myThread =newMyThread ();for(inti= ;i<= ;i++){thodName= method +String valueOf(i);newThread(myThread ) start();sleep( );}}}

运行结果如下

非静态的method 方法静态的method 方法

lishixin/Article/program/Java/gj/201311/27526

⑶ java多线程有几种实现方法,都是什么同步有几种实现方法,都是什么

java中多线程的实现方法有两种:1.直接继承thread类;2.实现runnable接口;同步的实现方法有五种:1.同步方法;2.同步代码块;3.使用特殊域变量(volatile)实现线程同步;4.使用重入锁实现线程同步;5.使用局部变量实现线程同步

其中多线程实现过程中需注意重写或者覆盖run()方法,而对于同步的实现方法中使用较常使用的是利用synchronized编写同步方法和代码块。

⑷ java多线程有几种实现方法线程之间如何同步

一、为什么要线程同步

因为当我们有多个线程要同时访问一个变量或对象时,如果这些线程中既有读又有写操作时,就会导致变量值或对象的状态出现混乱,从而导致程序异常。举个例子,如果一个银行账户同时被两个线程操作,一个取100块,一个存钱100块。假设账户原本有0块,如果取钱线程和存钱线程同时发生,会出现什么结果呢?取钱不成功,账户余额是100.取钱成功了,账户余额是0.那到底是哪个呢?很难说清楚。因此多线程同步就是要解决这个问题。

二、不同步时的代码

Bank.Java

packagethreadTest;

/**
*@authorww
*
*/
publicclassBank{

privateintcount=0;//账户余额

//存钱
publicvoidaddMoney(intmoney){
count+=money;
System.out.println(System.currentTimeMillis()+"存进:"+money);
}

//取钱
publicvoidsubMoney(intmoney){
if(count-money<0){
System.out.println("余额不足");
return;
}
count-=money;
System.out.println(+System.currentTimeMillis()+"取出:"+money);
}

//查询
publicvoidlookMoney(){
System.out.println("账户余额:"+count);
}
}

SyncThreadTest.java


packagethreadTest;


publicclassSyncThreadTest{

publicstaticvoidmain(Stringargs[]){
finalBankbank=newBank();

Threadtadd=newThread(newRunnable(){

@Override
publicvoidrun(){
//TODOAuto-generatedmethodstub
while(true){
try{
Thread.sleep(1000);
}catch(InterruptedExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
bank.addMoney(100);
bank.lookMoney();
System.out.println(" ");

}
}
});

Threadtsub=newThread(newRunnable(){

@Override
publicvoidrun(){
//TODOAuto-generatedmethodstub
while(true){
bank.subMoney(100);
bank.lookMoney();
System.out.println(" ");
try{
Thread.sleep(1000);
}catch(InterruptedExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
}
});
tsub.start();

tadd.start();
}



}

余额不足
账户余额:0


余额不足
账户余额:100


1441790503354存进:100
账户余额:100


1441790504354存进:100
账户余额:100


1441790504354取出:100
账户余额:100


1441790505355存进:100
账户余额:100


1441790505355取出:100
账户余额:100

三、使用同步时的代码

(1)同步方法:


即有synchronized关键字修饰的方法。由于java的每个对象都有一个内置锁,当用此关键字修饰方法时,内置锁会保护整个方法。在调用该方法前,需要获得内置锁,否则就处于阻塞状态。

修改后的Bank.java


packagethreadTest;

/**
*@authorww
*
*/
publicclassBank{

privateintcount=0;//账户余额

//存钱
(intmoney){
count+=money;
System.out.println(System.currentTimeMillis()+"存进:"+money);
}

//取钱
(intmoney){
if(count-money<0){
System.out.println("余额不足");
return;
}
count-=money;
System.out.println(+System.currentTimeMillis()+"取出:"+money);
}

//查询
publicvoidlookMoney(){
System.out.println("账户余额:"+count);
}
}

再看看运行结果:


余额不足
账户余额:0


余额不足
账户余额:0


1441790837380存进:100
账户余额:100


1441790838380取出:100
账户余额:0
1441790838380存进:100
账户余额:100
1441790839381取出:100
账户余额:0

瞬间感觉可以理解了吧。


注: synchronized关键字也可以修饰静态方法,此时如果调用该静态方法,将会锁住整个类

(2)同步代码块

即有synchronized关键字修饰的语句块。被该关键字修饰的语句块会自动被加上内置锁,从而实现同步

Bank.java代码如下:


packagethreadTest;

/**
*@authorww
*
*/
publicclassBank{

privateintcount=0;//账户余额

//存钱
publicvoidaddMoney(intmoney){

synchronized(this){
count+=money;
}
System.out.println(System.currentTimeMillis()+"存进:"+money);
}

//取钱
publicvoidsubMoney(intmoney){

synchronized(this){
if(count-money<0){
System.out.println("余额不足");
return;
}
count-=money;
}
System.out.println(+System.currentTimeMillis()+"取出:"+money);
}

//查询
publicvoidlookMoney(){
System.out.println("账户余额:"+count);
}
}

运行结果如下:

余额不足
账户余额:0


1441791806699存进:100
账户余额:100


1441791806700取出:100
账户余额:0


1441791807699存进:100
账户余额:100

效果和方法一差不多。

注:同步是一种高开销的操作,因此应该尽量减少同步的内容。通常没有必要同步整个方法,使用synchronized代码块同步关键代码即可。

(3)使用特殊域变量(volatile)实现线程同步


a.volatile关键字为域变量的访问提供了一种免锁机制
b.使用volatile修饰域相当于告诉虚拟机该域可能会被其他线程更新
c.因此每次使用该域就要重新计算,而不是使用寄存器中的值
d.volatile不会提供任何原子操作,它也不能用来修饰final类型的变量

Bank.java代码如下:


packagethreadTest;

/**
*@authorww
*
*/
publicclassBank{

privatevolatileintcount=0;//账户余额

//存钱
publicvoidaddMoney(intmoney){

count+=money;
System.out.println(System.currentTimeMillis()+"存进:"+money);
}

//取钱
publicvoidsubMoney(intmoney){

if(count-money<0){
System.out.println("余额不足");
return;
}
count-=money;
System.out.println(+System.currentTimeMillis()+"取出:"+money);
}

//查询
publicvoidlookMoney(){
System.out.println("账户余额:"+count);
}
}

运行效果怎样呢?


余额不足
账户余额:0


余额不足
账户余额:100


1441792010959存进:100
账户余额:100


1441792011960取出:100
账户余额:0


1441792011961存进:100
账户余额:100

是不是又看不懂了,又乱了。这是为什么呢?就是因为volatile不能保证原子操作导致的,因此volatile不能代替synchronized。此外volatile会组织编译器对代码优化,因此能不使用它就不适用它吧。它的原理是每次要线程要访问volatile修饰的变量时都是从内存中读取,而不是存缓存当中读取,因此每个线程访问到的变量值都是一样的。这样就保证了同步。


(4)使用重入锁实现线程同步

在JavaSE5.0中新增了一个java.util.concurrent包来支持同步。ReentrantLock类是可重入、互斥、实现了Lock接口的锁,它与使用synchronized方法和快具有相同的基本行为和语义,并且扩展了其能力。
ReenreantLock类的常用方法有:
ReentrantLock() : 创建一个ReentrantLock实例
lock() : 获得锁
unlock() : 释放锁
注:ReentrantLock()还有一个可以创建公平锁的构造方法,但由于能大幅度降低程序运行效率,不推荐使用
Bank.java代码修改如下:


packagethreadTest;

importjava.util.concurrent.locks.Lock;
importjava.util.concurrent.locks.ReentrantLock;

/**
*@authorww
*
*/
publicclassBank{

privateintcount=0;//账户余额

//需要声明这个锁
privateLocklock=newReentrantLock();

//存钱
publicvoidaddMoney(intmoney){
lock.lock();//上锁
try{
count+=money;
System.out.println(System.currentTimeMillis()+"存进:"+money);

}finally{
lock.unlock();//解锁
}
}

//取钱
publicvoidsubMoney(intmoney){
lock.lock();
try{

if(count-money<0){
System.out.println("余额不足");
return;
}
count-=money;
System.out.println(+System.currentTimeMillis()+"取出:"+money);
}finally{
lock.unlock();
}
}

//查询
publicvoidlookMoney(){
System.out.println("账户余额:"+count);
}
}

运行效果怎么样呢?


余额不足
账户余额:0


余额不足
账户余额:0


1441792891934存进:100
账户余额:100


1441792892935存进:100
账户余额:200


1441792892954取出:100
账户余额:100

效果和前两种方法差不多。


如果synchronized关键字能满足用户的需求,就用synchronized,因为它能简化代码 。如果需要更高级的功能,就用ReentrantLock类,此时要注意及时释放锁,否则会出现死锁,通常在finally代码释放锁

(5)使用局部变量实现线程同步


Bank.java代码如下:


packagethreadTest;


/**
*@authorww
*
*/
publicclassBank{

privatestaticThreadLocal<Integer>count=newThreadLocal<Integer>(){

@Override
protectedIntegerinitialValue(){
//TODOAuto-generatedmethodstub
return0;
}

};


//存钱
publicvoidaddMoney(intmoney){
count.set(count.get()+money);
System.out.println(System.currentTimeMillis()+"存进:"+money);

}

//取钱
publicvoidsubMoney(intmoney){
if(count.get()-money<0){
System.out.println("余额不足");
return;
}
count.set(count.get()-money);
System.out.println(+System.currentTimeMillis()+"取出:"+money);
}

//查询
publicvoidlookMoney(){
System.out.println("账户余额:"+count.get());
}
}

运行效果:


余额不足
账户余额:0


余额不足
账户余额:0


1441794247939存进:100
账户余额:100


余额不足
1441794248940存进:100
账户余额:0


账户余额:200


余额不足
账户余额:0


1441794249941存进:100
账户余额:300

看了运行效果,一开始一头雾水,怎么只让存,不让取啊?看看ThreadLocal的原理:


如果使用ThreadLocal管理变量,则每一个使用该变量的线程都获得该变量的副本,副本之间相互独立,这样每一个线程都可以随意修改自己的变量副本,而不会对其他线程产生影响。现在明白了吧,原来每个线程运行的都是一个副本,也就是说存钱和取钱是两个账户,知识名字相同而已。所以就会发生上面的效果。


ThreadLocal与同步机制
a.ThreadLocal与同步机制都是为了解决多线程中相同变量的访问冲突问题

b.前者采用以"空间换时间"的方法,后者采用以"时间换空间"的方式

热点内容
滑板鞋脚本视频 发布:2025-02-02 09:48:54 浏览:432
群晖怎么玩安卓模拟器 发布:2025-02-02 09:45:23 浏览:557
三星安卓12彩蛋怎么玩 发布:2025-02-02 09:44:39 浏览:743
电脑显示连接服务器错误 发布:2025-02-02 09:24:10 浏览:537
瑞芯微开发板编译 发布:2025-02-02 09:22:54 浏览:146
linux虚拟机用gcc编译时显示错误 发布:2025-02-02 09:14:01 浏览:235
java驼峰 发布:2025-02-02 09:13:26 浏览:651
魔兽脚本怎么用 发布:2025-02-02 09:10:28 浏览:538
linuxadobe 发布:2025-02-02 09:09:43 浏览:212
sql2000数据库连接 发布:2025-02-02 09:09:43 浏览:726