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

Цитата(OlegRu @ 15.12.2005, 16:25)

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

Да. Определись с задачей, нужны ли тебе два потока, первый ведь остановиться и будет ждать. Задача где реально нужно несколько потоков, это например загрузка файла под FTP с нескольких коннектов. Но и тогда можно передать ссылку загрузчикам на главное приложение, через которую они отдают инфу. При этом АПИ синхронизированно (synchronized методы), когда приходит последний кусок инфы, выполняем требуемое действие.

Другими словами не нужен C подход, где ты вызываешь метод обьекта и сам блокируешся, а после когда работа окончена, разблокируешся и пролжишь работу. Вместо этого раздели код на две части, первый метод поднимет MyNetworkSession, второй будет вызван самим MyNetworkSession когда работа будет выполненна.

Спасибо всем за участие!