什么是線程？

創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務，包含不限于成都網(wǎng)站制作、成都網(wǎng)站建設、舟山網(wǎng)絡推廣、微信小程序、舟山網(wǎng)絡營銷、舟山企業(yè)策劃、舟山品牌公關、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務，您的肯定，是我們最大的嘉獎；創(chuàng)新互聯(lián)為所有大學生創(chuàng)業(yè)者提供舟山建站搭建服務，24小時服務熱線：13518219792，官方網(wǎng)址：chinadenli.net

提到“線程”總免不了要和“進程”做比較，而我認為在Java并發(fā)編程中混淆的不是“線程”和“進程”的區(qū)別，而是“任務（Task）”。進程是表示資源分配的基本單位。而線程則是進程中執(zhí)行運算的最小單位，即執(zhí)行處理機調度的基本單位。關于“線程”和“進程”的區(qū)別耳熟能詳，說來說去就一句話：通常來講一個程序有一個進程，而一個進程可以有多個線程。

但是“任務”是很容易忽略的一個概念。我們在實際編碼中通常會看到這么一個包叫做xxx.xxx.task，包下是XxxTask等等以Task后綴名結尾的類。而XxxTask類通常都是實現(xiàn)Runnable接口或者Thread類。嚴格來說，“任務”和并發(fā)編程沒多大關系，就算是單線程結構化順序編程中，我們也可以定義一個Task類，在類中執(zhí)行我們想要完成的一系列操作?！叭蝿铡蔽艺J為是我們人為定義的一個概念，既抽象又具體，抽象在它指由軟件完成的一個活動，它可以是一個線程，也可以是多個線程共同達到某一目的的操作，具體在于它是我們認為指定實實在在的操作，例如：定時獲取天氣任務（定時任務），下線任務……關鍵就在于不要認為一個任務對應的就是一個線程，也許它是多個線程，甚至在這個任務中是一個線程池，這個線程池處理這個我們定義的操作。

我產(chǎn)生“線程”和“任務”的疑惑就是在《Thinking in Java》這本書的“并發(fā)”章節(jié)中它將線程直接定義為一個任務，在開篇標題就取名為“定義任務”,并且提到定義任務只需實現(xiàn)Runnable接口.而這個任務則是通過調用start來創(chuàng)建一改新的線程來執(zhí)行.說來說去有點繞,其實也不必糾結于在書中時而提到線程,時而提到人任務.我認為就記住:任務是我們在編程時所賦這段代碼的實際意義,而線程就關注它是否安全,是否需要安全,這就是后面要提到的線程安全問題.在像我一樣產(chǎn)生疑惑時,不用在意它兩者間的關系和提法。

什么是并發(fā)？

提到了并發(fā)，那又不得不和并行作比較。并發(fā)是指在一段時間內同時做多個事情，比如在1點-2點洗碗、洗衣服等。而并行是指在同一時刻做多個事情，比如1點我左手畫圓右手畫方。兩個很重要的區(qū)別就是“一段時間”和“同一時刻”.在操作系統(tǒng)中就是：

1) 并發(fā)就是在單核處理中同時處理多個任務。(這里的同時指的是邏輯上的同時)

2) 并行就是在多核處理器中同時處理多個任務。(這里的同時指的就是物理上的同時)

初學編程基本上都是單線程結構化編程，或者說是根本就接觸不到線程這個概念，反正程序照著自己實現(xiàn)的邏輯，程序一步一步按照我們的邏輯去實現(xiàn)并且得到希望輸出的結果。但隨著編程能力的提高，以及應用場景的復雜多變，我們不得不要面臨多線程并發(fā)編程。而初學多線程并發(fā)編程時，常常出現(xiàn)一些預料之外的結果，這就是涉及到“線程安全”問題。

什么線程安全？

這是在多線程并發(fā)編程中需要引起足夠重視的問題，如果你的線程不足夠“安全”，程序就可能出現(xiàn)難以預料，以及難以復現(xiàn)的結果?！禞ava并發(fā)編程實戰(zhàn)》提到對線程安全不好做一個定義，我的簡單理解就是：線程安全就是指程序按照你的代碼邏輯執(zhí)行，并始終輸出預定的結果。書中的給的定義：當多個線程訪問某個類時，這個類始終都能表現(xiàn)出正確的行為，那么就稱這個類是線程安全的。具體有關線程安全的問題，例如原子性、可見性等等不在這里做詳細闡述，適當?shù)臅r候會進行詳細介紹，簡單說一點，想要這個線程安全，得在訪問的時候給它上個鎖，不讓其他線程訪問，當然這種說法不嚴謹，不過可以暫時這么理解。

以上是從基本概念理論出發(fā)來大致了解需要知道的一些概念，下面就針對JDK中有關線程的API來對多線程并發(fā)編程做一個了解。

java.lang.Object
  -public void notify()//喚醒這個對象監(jiān)視器正在等待獲取鎖的一個線程
  -public void notifyAll()//喚醒這個對象監(jiān)視器上正在等待獲取鎖的所有線程
  -public void wait()//導致當前線程等待另一個線程調用notify()或notifyAll()
  -public void wait(long timeout)// 導致當前線程等待另一個線程調用notify()或notifyAll()，或者達到timeout時間
  -public void wait(long timeout, int nanos)//與上個方法相同，只是將時間控制到了納秒nanos

我們先用一個經(jīng)典的例子——生產(chǎn)者消費者問題來說明上面的API是如何使用的。生產(chǎn)者消費者問題指的的是，生產(chǎn)者生產(chǎn)產(chǎn)品到倉庫里，消費者從倉庫中拿，倉庫滿時生產(chǎn)者不能繼續(xù)生產(chǎn)，倉庫為空時消費者不能繼續(xù)消費。轉化成程序語言也就是生產(chǎn)者是一個線程

1，消費者是線程

2，倉庫是一個隊列，線程1往隊尾中新增，線程2從隊首中移除，隊列滿時線程1不能再新增，隊列空時線程2不能再移除。

package com.producerconsumer;

import java.util.Queue;



/**

 * 生產(chǎn)者

 * Created by yulinfeng on 2017/5/11.

 */

public class Producer implements Runnable{

  private final Queue<String> queue;

  private final int maxSize;

  public Producer(Queue<String> queue, int maxSize) {

    this.queue = queue;

    this.maxSize = maxSize;

  }
  public void run() {
    produce();
  }

  /**

   * 生產(chǎn)

   */

  private void produce() {

    try {
      while (true) {
        synchronized (queue) {
          if (queue.size() == maxSize) {
            System.out.println("生產(chǎn)者：倉庫滿了，等待消費者消費");
            queue.wait();
          }
          System.out.println("生產(chǎn)者:" + queue.add("product"));
          queue.notifyAll();
        }
      }
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
}

 

package com.producerconsumer;

import java.util.Queue;

/**

 * 消費者

 * Created by yulinfeng on 2017/5/11.

 */

public class Consumer implements Runnable {

  private final Queue<String> queue;
  public Consumer(Queue<String> queue) {
    this.queue = queue;
  }

  public void run() {
    consume();
  }

 

  /**

   * 消費

   */

  private void consume() {
    synchronized (queue) {
      try {
        while (true) {
          if (queue.isEmpty()) {
            System.out.println("消費者：倉庫空了，等待生產(chǎn)者生產(chǎn)");
            queue.wait();
          }
          System.out.println("消費者:" + queue.remove());
          queue.notifyAll();
        }
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }

}

 

package com.producerconsumer;

import java.util.LinkedList;
import java.util.Queue;

/**

 * Created by yulinfeng on 2017/5/11.

 */

public class Main {

  public static void main(String[] args) {

    Queue<String> queue = new LinkedList<String>();
    int maxSize = 100;
    Thread producer = new Thread(new Producer(queue, maxSize));
    Thread consumer = new Thread(new Consumer(queue));
    producer.start();
    consumer.start();

  }

}

這個生產(chǎn)者消費者問題的實現(xiàn)，我采用線程不安全的LinkedList，使用內置鎖synchronized來保證線程安全，在這里我們不討論synchronized，主要談notify()、notifyAll()和wait()。

在這里例子中，作為生產(chǎn)者，當隊列滿時調用了隊列的wait()方法，表示等待，并且此時釋放了鎖。作為消費者此時獲取到鎖并且移除隊首元素時調用了notifyAll()方法，此時生產(chǎn)者由wait等待狀態(tài)轉換為喚醒狀態(tài)，但注意！此時僅僅是線程被喚醒了，有了爭奪CPU資源的資格，并不代表下一步就一定是生產(chǎn)者生產(chǎn)，還有可能消費者繼續(xù)爭奪了CPU資源。一定記住是被喚醒了，有資格爭奪CPU資源。notifyAll()表示的是喚醒所有等待的線程，所有等待的線程被喚醒過后，都有了爭奪CPU資源的權利，至于是誰會獲得這個鎖，那不一定。而如果是使用notify()，那就代表喚醒所有等待線程中的一個，只是一個被喚醒具有了爭奪CPU的權力，其他沒被喚醒的線程繼續(xù)等待。如果等待線程就只有一個那么notify()和notifyAll()就沒區(qū)別，不止一個那區(qū)別就大了，一個是只喚醒其中一個，一個是喚醒所有。喚醒不是代表這個線程就一定獲得CPU資源一定獲得鎖，而是有了爭奪的權利。

java.lang.Thread
  -public void join()
  -public void sleep()
  -public static void yield()
  -……

針對Thread線程類，我們只說常見的幾個不容易理解的方法，其余方法不在這里做詳細闡述。

關于sleep()方法，可能很容易拿它和Object的wait方法作比較。兩個方法很重要的一點就是sleep不會釋放鎖，而wait會釋放鎖。在上面的生產(chǎn)者消費者的生產(chǎn)或消費過程中添加一行Thread.sleep(5000)，你將會發(fā)現(xiàn)執(zhí)行到此處時，這個跟程序都會暫停執(zhí)行5秒，不會有任何其他線程執(zhí)行，因為它不會釋放鎖。

關于join()方法，JDK7的解釋是等待線程結束（Waits for this thread to die）似乎還是不好理解，我們在main函數(shù)中啟動兩個線程，在啟動完這兩個線程后main函數(shù)再執(zhí)行其他操作，但如果不加以限制，有可能main函數(shù)率先執(zhí)行完需要的操作，但如果在main函數(shù)中加入join方法，則表示阻塞等待這兩個線程執(zhí)行結束后再執(zhí)行main函數(shù)后的操作，例如：

package com.join;


public class Main {

  public static void main(String[] args) throws Exception{
    Thread t1 = new Thread(new Task(0));
    Thread t2 = new Thread(new Task(0));
    t1.start();
    t2.start();
    t1.join();
    t2.join();
    System.out.print("main結束");
  }
}

上面?zhèn)€例子如果沒有join方法，那么“main”結束這條輸出語句可能就會先于t1、t2，加上在啟動線程的調用方使用了線程的join方法，則調用方則會阻塞線程執(zhí)行結束過后再執(zhí)行剩余的方法。

關于Thread.yield()方法，本來這個線程處于執(zhí)行狀態(tài)，其他線程也想爭奪這個資源，突然，這個線程不想執(zhí)行了想和大家一起來重新奪取CPU資源。所以Thread.yield也稱讓步。從下一章開始就正式開始了解java.util.concurrent。

以上這篇基于線程、并發(fā)的基本概念(詳解)就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持創(chuàng)新互聯(lián)。

分享標題：基于線程、并發(fā)的基本概念(詳解)
文章轉載：http://chinadenli.net/article44/jdjphe.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站建設、定制開發(fā)、外貿網(wǎng)站建設、網(wǎng)站制作、搜索引擎優(yōu)化、商城網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)