थ्रेड

Question

क्यों नहीं रोक सकता है क्यों मेरा धागा रोका नहीं जा सकता ???

class Threadz { 

    class runP implements Runnable { 
     int num; 
     private volatile boolean exit = false; 
     Thread t; 
     public runP() { 
      t = new Thread(this, "T1"); 
      t.start(); 
     } 

     @Override 
     public void run() { 
      while(!exit) { 
       System.out.println(t.currentThread().getName()+": "+num); 
       num++; 
       try { 
        t.sleep(200); 
       } catch(InterruptedException e) {} 
      } 
     } 
     public void stop() { 
      exit = true; 
     } 
    } 

    public static void main(String[] a) { 
     runP rp = new Threadz().new runP(); 
     if(rp.num == 1) {rp.stop();} 
    } 

} 

यदि मैं rp.num == 0 का उपयोग करता हूं, तो थ्रेड तुरंत बंद किया जा सकता है। लेकिन, जब मैंने rp.num == x बदल दिया (x 0 से अधिक संख्या है) धागा रुक नहीं सकता है? कृपया मुझे इस बात को हल करने में मदद करें ... किसी भी मदद के लिए धन्यवाद।

Answer 1

क्योंकि इस कोड धागे की विधि रन() में मार डाला नहीं है:

runP rp = new Threadz().new runP(); 
    if (rp.num == 1) { 
     rp.stop(); 
    } 

यह 0 के साथ काम करता के रूप में पूर्णांक का डिफ़ॉल्ट मान 0. है लेकिन यह आवश्यक रूप से सभी सज़ाएँ में सच नहीं है

: if (rp.num == 0)

runP धागे की रन विधि में बंद हालत में स्थानांतरित करें: runP का धागा चलाने के लिए और जांच से पहले num को बढ़ा सकता है के रूप में आवेदन की

Answer 2

मुझे यकीन है कि यदि आप प्रोग्राम को कई बार चलाते हैं, तो यह एक ऐसा मामला होगा जब कार्यक्रम वास्तव में बंद हो जाता है।

कारण आपकी run() विधि में

if(rp.num == 1) {rp.stop();} 

num++ से पहले

क्रियान्वित मूल्य में परिवर्तन की बहुत अधिक संभावना है बार जब आप प्रोग्राम चलाने पर है।

हालांकि मौके से आप एक मामले में आ सकते हैं कि आपकी मुख्य विधि में बयान अगर आपके रन विधि में लूप को निष्पादित किया जाता है।

उदहारण के लिए: यकीन है कि यह होता है लगातार हालत की जांच करने वाली बनाने के लिए

एक ही रास्ता

public static void main(String[] a) { 
    runP rp = new Threadz().new runP(); 

    while(true){ 
     if(rp.num == 1) { 
     rp.stop(); 
     break; 
     } 
    } 
} 

Answer 3

धागा रन विधि को निष्पादित करने से पहले निष्पादित किया जा रहा है।

if(rp.num == 1) {rp.stop();} 

ऊपर बयान से पहले Thread.Sleep जोड़ें, यह ठीक काम करता है के रूप में यह पाश शुरू करने के बाद इस बयान पर अमल होगा।

public static void main(String[] a) { 
    runP rp = new Threadz().new runP(); 
    try { 
     Thread.sleep(2000); 
    } catch (InterruptedException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
    if(rp.num > 1) {rp.stop();} 
} 

मैंने इसे परीक्षण करने के लिए 1 बनाया है।

Answer 4

rp.num == 1 की जांच करना ठीक उसी बिंदु पर होना होगा जहां rp.num बिल्कुल एक है, जो कि असंभव है।

अपने main विधि में, आप एक थ्रेड शुरू करते हैं जो हर 200 एमएस num बढ़ाता है। इसके बाद, आप num == 1 जांचते हैं, लेकिन जब यह कोड निष्पादित किया जाता है तो उन कई कारकों पर निर्भर करता है जिन्हें आप वास्तव में नियंत्रित नहीं कर सकते (ओएस का शेड्यूलिंग आदि ...)। यह 10 एमएस के बाद हो सकता है (जहां मान 1 होगा), लेकिन 300 एमएस के बाद भी हो सकता है (जब मान पहले से ही 2 है)। इसके अलावा जब धागा ठीक से शुरू होता है तो यह अनिश्चित है। इसलिए यह भी संभव है कि आपका धागा केवल परीक्षण के बाद शुरू होता है। आप आसानी से चेक if(rp.num == 1) {rp.stop()}; को एक साधारण प्रिंट स्टेटमेंट System.out.println(rp.num) के साथ बदलकर इसका परीक्षण कर सकते हैं। यदि आप प्रिंटिंग से पहले कुछ समय के लिए अतिरिक्त इंतजार करते हैं, तो आप इस बारे में बेहतर महसूस कर सकते हैं कि मैं किस बारे में बात कर रहा हूं।

आप मान लें कि बाहर से एक runnable बंद करना चाहते हैं, मैं Observer pattern की तरह कुछ का उपयोग करने के लिए सुझाव:

class MyRunnable implements Runnable { 

    private final MyListener l; 
    private volatile boolean exit; 
    int num; 

    public MyRunnable(MyListener l) { 
     this.l = l; 
     exit = false; 
    } 

    @Override 
    public void run() { 
     while(!exit) { 
      System.out.println(t.currentThread().getName()+": "+num); 
      l.check(num++); 
      try { 
       t.sleep(200); 
      } catch(InterruptedException e) {} 
     } 
    } 

    public void stop() { 
     exit = true; 
    } 
} 

class MyListener { 

    private final threshold; 

    public MyListener(int x) { 
     this.threshold = x; 
    } 

    public void check(MyRunnable r, int num) { 
     if (num >= threshold) 
      r.stop(); 
    } 

} 

और अपने मुख्य विधि की तरह

public static void main(String[] args) { 
    MyListener l = new MyListener(1); 
    Runnable r = new MyRunnable(l); 
    new Thread(r).start(); 
}