1. Из второго потока идет коннект к серверу, в итоге возвращается некая строка.
2. Эта строка должна отобразиться в первом потоке путем disp.setCurrent(tb);
3. Кажись, надо расставить здесь synchronized, wait() и notify(), но не знаю как?!
Подскажите, пожалуйста.

Код

public class  Main extends MIDlet implements CommandListener  {          ...     public Main(){      ...     }                public void commandAction(Command c, Displayable d){          if (c == connect)          {                disp.setCurrent(WaitForm);             s = new [b]MyNetworkSession();[/b]             s.start();     // [b]То, что ниже, выполняется гораздо быстрее чем то, что выше[/b]     // [b]Как сделать так, чтобы нижний блок ждал полного выполнения верхнего блока?[/b]          {                 tb = new TextBox("Test.php", s.getText(), 256, 0);                 tb.setCommandListener(this);                           [b]disp.setCurrent(tb);[/b]                                        }          }       }     } / ************** class MyNetworkSession extends GameCanvas implements Runnable {    ... public MyNetworkSession(){    ... }    public void start() {         Thread T = new Thread(this);       T.start();         stop=false;    }           public void run() {       try{          Request(URL);       }         catch (Exception e){     }  }     public void Request(String url) throws IOException{             ...     }  }

Это сообщение отредактировал(а) OlegRu - 13.12.2005, 18:41

s = new MyNetworkSession(this);
s.start();
synchronized(this){
wait();//ставим текущий поток в ожидание
}

...

private Main obj;
public MyNetworkSession(Main obj){
this.obj = obj;
...
}


public void run() {
try{
Request(URL);
synchronized(obj){
obj.notify(); //будим ждущий поток по завершении реквеста
}

}
catch (Exception e){
}
}


Это сообщение отредактировал(а) COVD - 13.12.2005, 19:57

COVD по моему ошибка с синхорнизацией,

Код

synchronized(this){   wait();//ставим текущий поток в ожидание }

Лочим на свой instance, внутри synchronized первый получивший тред уверен, что все остальные потоки будут блокироваться на этом обьекте, НО:

Код

synchronized(obj){ obj.notify(); //будим ждущий поток по завершении реквеста }

получаеться второй тред залочиться на synchronized(obj) и будет ждать пока первый поток отпусит обьект (выйдет из synchronized). Так как первый поток ждёт события, от заблокированного второго получаем deadlock... хотя до концане уверен
Добавлено @ 01:33
Также задачу можно порешать вложенным классом, обьекто которог передадим MyNetworkSession. Вложенный класс будет играть роль listener'а события "готово" и возобновит работу. Всё может уложиться в одном потоке.

To COVD
Спасибо, я вроде понял суть в принципе. Сделал точно как вы написали.
To Sardar
А вы действительно правы, второй поток MyNetworkSession попадает в дедлок.
Появляется сообщение о разрешении подключиться к инету и приложение замирает в молчании
Что мне делать, как мне быть?
А можно поподробнее о том, как сделать все в одном потоке (если нельзя в разных).
Благодарю за ваше участие!

Код

public class Main extends MIDlet implements CommandListener {      ...     private MyNetworkSession s;          public Main(){     disp = Display.getDisplay(this);     game = new Canva(this);          }         public void startApp(){      ...     }     ...     public void commandAction(Command c, Displayable d){         if (c == account)         {              URL="http://localhost/test.php?e=Account&id=68584576376";                         s = new MyNetworkSession(this);             s.start();             try{                  synchronized(this){                      wait();//ставим текущий поток в ожидание                  }             }             catch (Exception e){}                          Alert reg_alert = new Alert("Ваш счет", "",null,null);             disp.setCurrent(reg_alert);        }                              }  }  // End of class Main

Код

class MyNetworkSession extends GameCanvas implements Runnable { private String URL; private Main obj;          public MyNetworkSession(Main obj) {     ...     this.obj = obj;     URL = obj.URL;  } public void start() {       Thread T = new Thread(this);     T.start();   }          public void run() {        try{         Request(URL);         synchronized(obj){             obj.notify(); // будим ждущий поток по завершении реквеста         }     }         catch (Exception e){     }  } public void Request(String url) throws IOException{              ... }  } // End of class MyNetworkSession

Цитата

по моему ошибка с синхорнизацией,

Нет, для wait и notify как раз так и надо делать, синхронизировать один и тот же обьект. В других случаях будет lock.

To COVD
А мне что с потоками делать?
Сейчас в таком виде (выше) не работает.

определите , в каком месте проблема возникает. Расставьте System.out.println("..."), чтобы определить последовательность выполняемых операций.

To COVD
Да, я расставил, где надо, println, и оказалось, что вся работа виснет при входе в метод Request(String url), а именно после вызова Connector.open(url); Но раньше (без этой синхронизации) коннект шел без проблем.

Код

public void Request(String url) throws IOException {                 InputStream iStrm = null;     int rc;     try{              System.out.println("Flag in Request");  // эту строку выводит       con = (HttpConnection)Connector.open(url);               System.out.println("Flag in Request1"); // а после open(url) нет никакой жизни :(       con.setRequestMethod(con.GET);             rc=con.getResponseCode();       if ( rc== con.HTTP_OK)       {         String str;         iStrm = con.openInputStream();         int length = (int) con.getLength();         if (length != -1)         {           byte serverData[] = new byte[length];           iStrm.read(serverData);           str = new String(serverData);         }         else         {           ByteArrayOutputStream bStrm = new ByteArrayOutputStream();                  int ch;           while ((ch = iStrm.read()) != -1)             bStrm.write(ch);              str = new String(bStrm.toByteArray());           bStrm.close();                         }            text="File Contents: "+str;         System.out.println(text);       }     }     catch (Exception e)     {         System.err.println("Msg: ERROR:");         e.toString();         e.printStackTrace();         e.getMessage();     }      finally      {       if (iStrm != null) { iStrm.close(); }       if (con != null) { con.close(); }     } }

http://forum.vingrad.ru/index.php?act=modu...nel&article=102

Во-первых: не уловил что это за метод такой в MyNetworkSession

Код

public void start() {       Thread T = new Thread(this);     T.start();   }

а кто тогда вызывается (public void run() или этот start()), когда делаем s.start(); из public void commandAction(Command c, Displayable d)

Во-вторых: добавь просмотр отлавливаемых Exception как в этом коде, я так думаю, туда попасть должен твой IOException из Request(String url) который у тебя стоит как throws, и поэтому он у тебя не попадёт в твой catch из Request метода

Код

public void run() {        try{         Request(URL);         synchronized(obj){             obj.notify(); // будим ждущий поток по завершении реквеста         }     }         catch (Exception e){            obj.notify();            e.printStackTrace();     }

Ребята, спасибо за ваше внимание.
Значит-ца так. Я уже брожу два дня по инету в поисках решения проблемы и только-что наткнулся на это:
Topic: thread + connector.open
Оказывается, там тоже была некоторая проблема с одинаковым "корнем". Там человек жаловался на Connector.open(defaultURL), после которого у меня застывала программа.
Тогда пришла мысль полностью закомментировать код в методе Request(String url) и написать так:

Код

public void Request(String url) throws IOException {                 try{                     // Это поставил специально чтоб "потянуть время"            // Можно и цикл сделать длинный             try { Thread.sleep(10000); }              catch (java.lang.InterruptedException e) {}         text="File Contents: ";         System.out.println(text);     }     catch (Exception ee)     {         System.err.println("Msg: ERROR:");         ee.printStackTrace();     }  }

Теперь потоки ЗАМЕЧАТЕЛЬНО синхронизируются!! Первый поток ждет, пока пройдут 10 секунд во втором потоке, последний возвращает строку "File Contents: " первому потоку. И первый поток отображает ее в своем Алерте.
Так что само устройство синхронизации потоков для этого случая, подсказанное COVD'ом, правильно на самом деле!
Единственная беда, я не знаю как же быть с самим Connector.open !!
Почему так происходит?? Или я еще не понимаю всей глубины происходящего!
Если кто хочет разобраться,- то давайте вместе. Мне это очень надо

а это не поможет?
Connector.open("http://ya.ru",Connector.READ, true);

To Dancer
Не, не помогает это.

я уже понял что не помогате, сейчас подекомпилил классы, так вот что обнаружил, этот параметр в конечном счёте игнорируется в методе, где происходит непосредственный коннект.
вот так то.....................

To Sardar
Получается, что вообще можно обойтись без синхронизации, например, так:

В классе Main:

Код

public void displayAlert()  {     Alert reg_alert = new Alert("dfh", s.text,null,null);      disp.setCurrent(reg_alert);  }

В классе MyNetworkSession сразу после метода Request(String url):

Код

obj.displayAlert();

Я пробовал, так работает хорошо.


To Dancer
Я поставил Exception так:

Код

catch (Exception e){                obj.notify(); // <----                e.printStackTrace();         }

но все равно не выдается мне почему-то текст ошибки.

Это сообщение отредактировал(а) OlegRu - 15.12.2005, 17:56