上篇文章知識介紹了多線程的創建和啟動問題，各個子線程和子線程或者說子線程和main線程沒有信息的交流，這篇文章主要探討線程之間信息共享以及交換問題。這篇文章主要以一個賣票例子來展開。

繼承Thread重寫run方法進行實現

初始代碼：

public class Tickect1 {

public static void main(String[] args) {

//創建四個線程進行測試

new Thread3().start();

new Thread3().start();

new Thread3().start();

new Thread3().start();

}

}

class Thread3 extends Thread{

private static int tickets = 100;//總票數

@Override

public void run() {

while(true){

if(tickets<=0){

break;

}else{

System.out.println(Thread.currentThread().getName()+" "+tickets);

tickets--;

}

}

}

}

錯誤答案：賣了103張票

分析原因：1.類似于i++的操作不是原子操作

四個進程有四個工作緩存，每次都是修改工作緩存的數據，而且四個工作緩存之間的數據無法共享，倒置在緩存1中已經tickets-1，但是緩存2中tickets又無法獲取1中緩存的數據所以票會增大，所以出現103 2.關鍵步驟缺少加鎖操作(獲取票數和對票數-1的操作同時執行會出現問題)

改進的代碼：這個代碼有bug，測試答案還是103

public class Tickect1 {

public static void main(String[] args) {

//創建四個線程進行測試

new Thread3().start();

new Thread3().start();

new Thread3().start();

new Thread3().start();

}

}

class Thread3 extends Thread{

private static volatile int tickets = 100;//總票數

@Override

public void run() {

while(true){

sale();

if(tickets<=0) break;

}

}

public synchronized void sale(){//對數據修改進行加鎖(同一時刻只能一個線程執行)

if(tickets>0){

System.out.println(Thread.currentThread().getName()+" "+tickets);

tickets--;

}

}

}

實現Runnable的run方法進行實現

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起到通知各個線程緩存區的數據是否修改，如果修改就刷新緩沖區數據(變量副本的解決方法)

String str = new String("");//對這個對象加鎖

@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對數據修改進行加鎖(同一時刻只能一個線程執行)

if(tickets>0){//必須在這里判斷，if放在外面會出現錯誤

System.out.println(Thread.currentThread().getName()+" "+tickets);

tickets--;

}

}

}

volatile關鍵字測試

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; //子線程不會停止

volatile boolean flag = true; //用volatile修飾的變量可以及時在各線程里面通知

public void run()

{

int i=0;

while(flag)

{

i++;

}

System.out.println("test thread3 is exiting");

}

}

總結

以上是生活随笔為你收集整理的java多线程共享信息_java多线程信息共享的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。