java多线程共享信息_java多线程信息共享
上篇文章知識(shí)介紹了多線程的創(chuàng)建和啟動(dòng)問(wèn)題，各個(gè)子線程和子線程或者說(shuō)子線程和main線程沒有信息的交流，這篇文章主要探討線程之間信息共享以及交換問(wèn)題。這篇文章主要以一個(gè)賣票例子來(lái)展開。
繼承Thread重寫run方法進(jìn)行實(shí)現(xiàn)
初始代碼：
public class Tickect1 {
public static void main(String[] args) {
//創(chuàng)建四個(gè)線程進(jìn)行測(cè)試
new Thread3().start();
new Thread3().start();
new Thread3().start();
new Thread3().start();
}
}
class Thread3 extends Thread{
private static int tickets = 100;//總票數(shù)
@Override
public void run() {
while(true){
if(tickets<=0){
break;
}else{
System.out.println(Thread.currentThread().getName()+" "+tickets);
tickets--;
}
}
}
}
錯(cuò)誤答案：賣了103張票
分析原因：1.類似于i++的操作不是原子操作
四個(gè)進(jìn)程有四個(gè)工作緩存，每次都是修改工作緩存的數(shù)據(jù)，而且四個(gè)工作緩存之間的數(shù)據(jù)無(wú)法共享，倒置在緩存1中已經(jīng)tickets-1，但是緩存2中tickets又無(wú)法獲取1中緩存的數(shù)據(jù)所以票會(huì)增大，所以出現(xiàn)103 2.關(guān)鍵步驟缺少加鎖操作(獲取票數(shù)和對(duì)票數(shù)-1的操作同時(shí)執(zhí)行會(huì)出現(xiàn)問(wèn)題)
改進(jìn)的代碼：這個(gè)代碼有bug，測(cè)試答案還是103
public class Tickect1 {
public static void main(String[] args) {
//創(chuàng)建四個(gè)線程進(jìn)行測(cè)試
new Thread3().start();
new Thread3().start();
new Thread3().start();
new Thread3().start();
}
}
class Thread3 extends Thread{
private static volatile int tickets = 100;//總票數(shù)
@Override
public void run() {
while(true){
sale();
if(tickets<=0) break;
}
}
public synchronized void sale(){//對(duì)數(shù)據(jù)修改進(jìn)行加鎖(同一時(shí)刻只能一個(gè)線程執(zhí)行)
if(tickets>0){
System.out.println(Thread.currentThread().getName()+" "+tickets);
tickets--;
}
}
}
實(shí)現(xiàn)Runnable的run方法進(jìn)行實(shí)現(xiàn)
public class Ticket2 {
public static void main(String[] args) {
Thread4 t = new Thread4();
new Thread(t).start();
new Thread(t).start();
new Thread(t).start();
new Thread(t).start();
}
}
class Thread4 implements Runnable{
private volatile int tickets=100;//volatile起到通知各個(gè)線程緩存區(qū)的數(shù)據(jù)是否修改，如果修改就刷新緩沖區(qū)數(shù)據(jù)(變量副本的解決方法)
String str = new String("");//對(duì)這個(gè)對(duì)象加鎖
@Override
public void run() {
while (true){
//sale();方式1
synchronized (str){//代碼快加鎖(方式2)
if(tickets>0){
System.out.println(Thread.currentThread().getName()+" "+tickets);
tickets--;
}
}
if(tickets<=0) break;
}
}
public synchronized void sale(){//synchronized對(duì)數(shù)據(jù)修改進(jìn)行加鎖(同一時(shí)刻只能一個(gè)線程執(zhí)行)
if(tickets>0){//必須在這里判斷，if放在外面會(huì)出現(xiàn)錯(cuò)誤
System.out.println(Thread.currentThread().getName()+" "+tickets);
tickets--;
}
}
}
volatile關(guān)鍵字測(cè)試
public class ThreadDemo2
{
public static void main(String args[]) throws Exception
{
TestThread2 t = new TestThread2();
t.start();
Thread.sleep(2000);
t.flag = false;
System.out.println("main thread is exiting");
}
}
class TestThread2 extends Thread
{
//boolean flag = true; //子線程不會(huì)停止
volatile boolean flag = true; //用volatile修飾的變量可以及時(shí)在各線程里面通知
public void run()
{
int i=0;
while(flag)
{
i++;
}
System.out.println("test thread3 is exiting");
}
}
總結(jié)
以上是生活随笔為你收集整理的java多线程共享信息_java多线程信息共享的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： java如何做测试数据库_如何模拟用于测
- 下一篇： ig信息增益 java_文本分类综述