Форум программистов [Powered by Invision Power Board]

Код


Thread t = new Thread(){
  public void run(){
     Runtime runtime = Runtime.getRuntime();
     Process p = runtime.exec("task1.bat");
     new Startruntime(p, 650);
  
     p = runtime.exec("task2.bat");
     new Startruntime(p, 1000);
//.....

  }

}
t.setName("Basic thread");
t.start();

Код


public class Startruntime{

 Process p;
 Thread t1,t2;
 int limit;
 boolean isValue;

 public Startruntime(Process p, int limit) {
    
  this.p = p;
  this.limit = limit;

  try {
    go();
  } catch (InterruptedException e) {
    e.printStackTrace();
    }
        
 }

 synchronized void go() throws InterruptedException{
        
        
     t1 = new LoadBar("asdasd");
     t1.setName("one thread");
     t2 = new WaitFor(p);
     t2.setName("two thread");
        
     t1.start();
     t2.start();
     wait(); // "Basic thread" уснул
    
     System.out.println("unreachable");
     System.out.println("awake");
     System.out.println("awake");
     System.out.println("awake");
     t1.join();
     t2.join();


 class LoadBar extends Thread{

  public void run{

   synchronized (this) {
    while (true) {
     if (isValue) {
      break;
     }
    }
    notify(); //а здесь "Basic thread" не хочет просыпается!!
    //notifyAll();
    frame.dispose();
   }
  }

 }

 class WaitFor extends Thread{

  public void run(){
   p.waitFor();
   isValue = true;
  }

 }

}

Цитата(Orange @ 31.7.2008, 18:21

)

как его вызвать в LoadBar-е на объекте Startruntime?

Код


51:        Startruntime.this.notify(); //а здесь "Basic thread" не хочет просыпается!!

Код


synchronized (Startruntime.this)

Код


public class Main{

 public static void main(String[] args){

 Thread basicThread = new BasicThread("test1");
 basicThread.setName("Basic Thread");
 basicThread.start();

 }
}

Код


import java.io.*; 

public class BasicThread extends Thread{

 String name;

 public BasicThread(String name){

  this.name = name;
 }

 public void run(){

  prepareProcess(name);
 }

 void prepareProcess(String name){

  ProcessClass procClass = new ProcessClass(name);
  try{
  procClass.startProcess();
  }
  catch(IOException ioe){
   ioe.printStackTrace();
  }

 } 
}

Код


import java.io.*;

public class ProcessClass{

 String name;
 Startruntime str;

 public ProcessClass(String name){
  
  this.name = name;
 }

 void startProcess() throws IOException{

  Runtime runtime = Runtime.getRuntime();
  Process p = runtime.exec("l.bat");  
  str = new Startruntime(p, 650);

  p = runtime.exec("l.bat");  
  str = new Startruntime(p, 300);

 }
}

Код


import java.io.*;
import javax.swing.*;

public class Startruntime{

 Thread t1,t2;
 Process p;
 int limit;
 boolean isValue;

 public Startruntime(Process p,int limit){

  this.p = p;
  this.limit = limit;
  
  try{
    go();
  }catch (InterruptedException e){
    e.printStackTrace();
  }

 }

 void go() throws InterruptedException{

  t1 = new LoadBar();
  t1.setName("one thread");
  t2 = new WaitFor(p);
  t2.setName("two thread");

  t1.start();
  Thread.sleep(100);
  t2.start();
  System.out.println("before wait");

 //synchronized (this) {
  System.out.println(Thread.currentThread().getName() + " in wait");
  wait();
  System.out.println(Thread.currentThread().getName() + " end wait");
 //}

 
  System.out.println("awake");

  t1.join();
  t2.join();
  System.out.println(Thread.currentThread().getName());

 }

 class LoadBar extends Thread{

  JFrame frame;
  LoadBar(){

   JFrame.setDefaultLookAndFeelDecorated(true);
   frame = new JFrame();
   frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
   //JComponent newContentPane = new PrgBar(limit);
   //newContentPane.setOpaque(true);
   //frame.setContentPane(newContentPane);
   frame.pack();
   frame.setLocationRelativeTo(null);
   frame.setVisible(true);

  }

  public void run() {


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

    synchronized (Startruntime.this){

    while (true) {
     if (isValue) {
      Startruntime.this.notify();
       System.out.println("asasas");
       break;
     }
    }
    frame.dispose();
       }
    }
 }

 class WaitFor extends Thread {
 
  Process p;
   
  WaitFor(Process p){
   this.p = p;
  }

  public void run() {

   try{

    System.out.println(Thread.currentThread().getName() + "in WaitFor");
    p.waitFor();
    isValue = true;

   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
 }

}

Код


void go(){
//....
synchronized (this) {
  System.out.println(Thread.currentThread().getName() + " in wait");
  wait();
  System.out.println(Thread.currentThread().getName() + " end wait");
}
}