如何實現(xiàn)java線程同步?很多新手對此不是很清楚,為了幫助大家解決這個難題,下面小編將為大家詳細講解,有這方面需求的人可以來學習下,希望你能有所收獲。
走過十載,我們已為眾多企業(yè)及政府機關(guān)提供專業(yè)的互聯(lián)網(wǎng)服務(wù)。我們不只是一家專業(yè)的建站公司;我們對營銷、技術(shù)、服務(wù)都有自己獨特見解,成都創(chuàng)新互聯(lián)采取“創(chuàng)意+綜合+營銷”一體化的方式為您提供更專業(yè)的服務(wù)!成都創(chuàng)新互聯(lián)經(jīng)歷的每一步也許不一定是最完美的,但每一步都有值得深思的意義。
為什么線程同步
當我們有多個線程要對同一個資源進行操作的時候,比如說文件,這時候就不能讓多個線程同時操作這個文件了。因為當文件共享的時候,多個操作就會產(chǎn)生沖突。相信使用過git進行團隊開發(fā)的人就會有比價深刻的體會。
這時候就需要引入線程的同步機制。
所謂同步,是指一個一個執(zhí)行,也就是排隊,幾個線程排隊執(zhí)行,讓線程之間有一個先來后到的關(guān)系。這樣,就不會產(chǎn)生爭搶的現(xiàn)象,也就不會出現(xiàn)沖突。
問題描述
一個有兩個線程的程序,第一個線程計算2~1000之間的偶數(shù)及個數(shù),第二個線程計算1000~2000之間的偶數(shù)及個數(shù)。
初步實現(xiàn)
首先,我們根據(jù)題目來設(shè)計一下實現(xiàn)方式。
1.定義兩個線程。這里要定義自己的線程類,然后去設(shè)置計算偶數(shù)的開始和結(jié)束
2.實現(xiàn)計算所給范圍內(nèi)的偶數(shù)和偶數(shù)個數(shù)
3.執(zhí)行線程
可以看到實現(xiàn)方式很簡單。初步實現(xiàn)如下:
1.定義自己的線程類:
public class MyTread extends Thread { private int begin; // 范圍開始 private int end; // 范圍結(jié)束 public MyTread(int begin, int end) { this.begin = begin; this.end = end; } }
2.實現(xiàn)計算偶數(shù)以及偶數(shù)個數(shù)
@Override public void run() { this.getEven(begin, end); } // 獲取偶數(shù)以及個數(shù) private void getEven(int begin, int end) { int count = 0; System.out.println(begin + "~" + end + "之間的偶數(shù)為:"); if (begin % 2 != 0) { begin += 1; } for (; begin <= end; begin += 2) { System.out.print(begin + " "); count++; } System.out.println(); System.out.println("偶數(shù)個數(shù)為:" + count); }
3.初始化線程,運行
public static void main(String[] args) { MyTread tread1 = new MyTread(2, 500); MyTread tread2 = new MyTread(500, 1000); tread1.start(); tread2.start(); }
注:這里為了展示后面的效果,所以將數(shù)字范圍減小。
看一下結(jié)果:
好像并不是我們想要的效果。我們想要這樣的效果:
我們想要每一部分的偶數(shù)和偶數(shù)個數(shù)都在一起,但是我們實現(xiàn)后的效果確實兩部分混亂出現(xiàn)的。
程序完善
要解決上面出現(xiàn)的問題,就要用到我們最開始說的線程同步
了。
根據(jù)我們開始的介紹,發(fā)現(xiàn)實現(xiàn)同步的一個條件就是有一個共享的資源
。那么我們的代碼里什么是這個共享的資源
呢?貌似沒有。所以先創(chuàng)建一個。
1.建立共享資源
我們這里的共享資源完全就可以是同一個對象
,所以我們就另外建立一個類,用來示例共享資源。
public class Even {}
2.然后在共享類中建立計算偶數(shù)的方法:
public class Even { /** * 獲取某個范圍內(nèi)偶數(shù)以及個數(shù) * @param begin 統(tǒng)計開始 * @param end 統(tǒng)計結(jié)束 */ public synchronized void getEven(int begin, int end) { int count = 0; System.out.println(begin + "~" + end + "之間的偶數(shù)為:"); if (begin % 2 != 0) { begin += 1; } for (; begin <= end; begin += 2) { System.out.print(begin + " "); count++; } System.out.println(); System.out.println("偶數(shù)個數(shù)為:" + count); } }
細心的人會發(fā)現(xiàn),這個方法跟我們最開始寫的方法有點不同,它多了一個關(guān)鍵字:synchronized
。通過這個關(guān)鍵字,我們就能在執(zhí)行方法的時候,實現(xiàn)線程同步了。
3.最后在線程中調(diào)用共享方法
public class MyTread extends Thread { Even even; @Override public void run() { even.getEven(begin, end); } }
這時候,我們再來執(zhí)行一下:
實現(xiàn)了我們想要的效果。
最后,附上完整代碼:
/** * 偶數(shù)類 */ public class Even { /** * 獲取某個范圍內(nèi)偶數(shù)以及個數(shù) * @param begin 統(tǒng)計開始 * @param end 統(tǒng)計結(jié)束 */ public synchronized void getEven(int begin, int end) { int count = 0; System.out.println(begin + "~" + end + "之間的偶數(shù)為:"); if (begin % 2 != 0) { begin += 1; } for (; begin <= end; begin += 2) { System.out.print(begin + " "); count++; } System.out.println(); System.out.println("偶數(shù)個數(shù)為:" + count); } } public class MyTread extends Thread { Even even; private int begin; // 范圍開始 private int end; // 范圍結(jié)束 public MyTread(Even even, int begin, int end) { this.even = even; this.begin = begin; this.end = end; } @Override public void run() { even.getEven(begin, end); } public static void main(String[] args) { Even even = new Even(); MyTread tread1 = new MyTread(even, 2, 500); MyTread tread2 = new MyTread(even, 500, 1000); tread1.start(); tread2.start(); } }
看完上述內(nèi)容是否對您有幫助呢?如果還想對相關(guān)知識有進一步的了解或閱讀更多相關(guān)文章,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝您對創(chuàng)新互聯(lián)的支持。
本文標題:如何實現(xiàn)java線程同步
文章分享:http://bm7419.com/article40/gejpeo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站收錄、用戶體驗、App設(shè)計、App開發(fā)、域名注冊、做網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)