首頁  >  文章  >  Java  >  java執行緒同步的實作方法詳解(附程式碼)

java執行緒同步的實作方法詳解(附程式碼)

不言
不言轉載
2018-10-19 16:14:172682瀏覽

這篇文章帶給大家的內容是關於java執行緒同步的實作方法詳解(附程式碼),有一定的參考價值,有需要的朋友可以參考一下,希望對你有幫助。

為什麼執行緒同步

當我們有多個執行緒要對同一個資源進行操作的時候,比如說文件,這時候就不能讓多個執行緒同時操作這個文件了。因為當檔案共享的時候,多個操作就會產生衝突。相信使用過git團隊開發的人會有比價深刻的體會。

這時候就需要引入線程的同步機制。

所謂同步,是指一個一個執行,也就是排隊,幾個執行緒排隊執行,讓執行緒之間有一個先來後到的關係。這樣,就不會產生爭搶的現象,也不會有衝突。

問題描述

一個有兩個執行緒的程序,第一個執行緒計算2~1000之間的偶數及個數,第二個執行緒計算1000 ~2000之間的偶數及個數。

初步實作

首先,我們根據題目來設計一下實作方式。

1.定義兩個執行緒。這裡要定義自己的線程類,然後去設定計算偶數的開始和結束
2.實現計算所給範圍內的偶數和偶數個數
3.執行線程

可以看到實作方式很簡單。初步實作如下:

1.定義自己的執行緒類別:

public class MyTread extends Thread {
    private int begin;          // 范围开始
    private int end;            // 范围结束

    public MyTread(int begin, int end) {
        this.begin = begin;
        this.end = end;
    }
}

2.實作計算偶數以及偶數個數

@Override
public void run() {
    this.getEven(begin, end);
}

// 获取偶数以及个数
private void getEven(int begin, int end) {
    int count = 0;
    System.out.println(begin + "~" + end + "之间的偶数为:");
    if (begin % 2 != 0) {
        begin += 1;
    }

    for (; begin  <p><strong>3.初始化線程,運行</strong></p><pre class="brush:php;toolbar:false">public static void main(String[] args) {
    MyTread tread1 = new MyTread(2, 500);
    MyTread tread2 = new MyTread(500, 1000);
    tread1.start();
    tread2.start();
}

註:這裡為了展示後面的效果,所以將數字範圍減少。

看一下結果:

java執行緒同步的實作方法詳解(附程式碼)

#好像不是我們想要的效果。我們想要這樣的效果:

java執行緒同步的實作方法詳解(附程式碼)

我們想要每一部分的偶數和偶數個數都在一起,但是我們實現後的效果確實兩部分混亂出現的。

程式完善

要解決上面出現的問題,就要用到我們最開始說的執行緒同步了。

根據我們開始的介紹,發現實現同步的一個條件就是有一個共享的資源。那我們的程式碼裡什麼是這個共享的資源呢?貌似沒有。所以先創建一個。

1.建立共享資源

我們這裡的共享資源完全就可以是同一個物件,所以我們就另外建立一個類,用來範例共享資源。

public class Even {}

2.然後在共享類別中建立計算偶數的方法:

public class Even {
    /**
     * 获取某个范围内偶数以及个数
     * @param begin 统计开始
     * @param end   统计结束
     */
    public synchronized void getEven(int begin, int end) {
        int count = 0;
        System.out.println(begin + "~" + end + "之间的偶数为:");
        if (begin % 2 != 0) {
            begin += 1;
        }

        for (; begin <p>細心的人會發現,這個方法跟我們最開始寫的方法有點不同,它多了一個關鍵字:<code>synchronized</code>。透過這個關鍵字,我們就能在執行方法的時候,實現執行緒同步了。 </p><p><strong>3.最後在執行緒中呼叫共享方法</strong></p><pre class="brush:php;toolbar:false">public class MyTread extends Thread {
    Even even;
    
    @Override
    public void run() {
        even.getEven(begin, end);
    }
}

這時候,我們再來執行一下:

java執行緒同步的實作方法詳解(附程式碼)

##實現了我們想要的效果。

最後,附上完整程式碼:

/**
 * 偶数类
 */
public class Even {
    /**
     * 获取某个范围内偶数以及个数
     * @param begin 统计开始
     * @param end   统计结束
     */
    public synchronized void getEven(int begin, int end) {
        int count = 0;
        System.out.println(begin + "~" + end + "之间的偶数为:");
        if (begin % 2 != 0) {
            begin += 1;
        }

        for (; begin <p class="comments-box-content"><br>#</p>

以上是java執行緒同步的實作方法詳解(附程式碼)的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:segmentfault.com。如有侵權,請聯絡admin@php.cn刪除