VPF::обить поток... - Форум программистов

LSD

Дата 13.4.2007, 15:14 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Thread.join() - останавливает текущий поток, до тех пор пока не остановится тот поток у которого был вызван join(). Например:

Код

public boolean excute(Runnable task)
{
  Thread thread = new Thread(task);
  thread.start();
  try
  {
    thread.join(10 * 1000);
  }
  catch(InterruptedException e)
  {
    return false;
  }
  return true;
}

будет создан еще один поток, в котором будет запущена некая задача. Далее текущий поток будет ждать 10 секунд завершения этой задачи, если дождется, то вернет true иначе false.

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

kkorsakoff

Дата 13.4.2007, 15:21 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 378
Регистрация: 18.10.2005
Где: Санкт-Петербург

Репутация: 3
Всего: 14

Цитата(LSD @ 12.4.2007, 12:04)

Вот что написано в JavaDoc по interrupt():

Цитата

If this thread is blocked in an I/O operation upon an interruptible channel then the channel will be closed, the thread's interrupt status will be set, and the thread will receive a ClosedByInterruptException.

Файловые и сетевые каланы - interruptible, но в принципе могут быть каналы, которые не interruptible.

Это понятно, а на практике?

Boing747

Дата 13.4.2007, 15:27 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 89
Регистрация: 19.2.2007

Репутация: 1
Всего: 2

Цитата

Thread.join() - метод который останавливает поток до его удаления... так написано в АПИ... если я все правильно понял...???

Этот метод используют для того, чтобы дождаться пока остальные потоки не остановятся.

Код



class MyThread implements Runnable {
      String name; // name of thread

      Thread t;

      MyThread(String threadname) {
        name = threadname;
        t = new Thread(this, name);
        System.out.println("New thread: " + t);
        t.start();
      }

      public void run() {
        try {
          for (int i = 5; i > 0; i--) {
            System.out.println(name + ": " + i);
            Thread.sleep(1000);
          }
        } catch (InterruptedException e) {
          System.out.println(name + " interrupted.");
        }
        System.out.println(name + " exiting.");
      }
    }

    public class Test {
      public static void main(String args[]) {
        MyThread ob1 = new MyThread("One");
        MyThread ob2 = new MyThread("Two");
        MyThread ob3 = new MyThread("Three");

        System.out.println("Thread One is alive: " + ob1.t.isAlive());
        System.out.println("Thread Two is alive: " + ob2.t.isAlive());
        System.out.println("Thread Three is alive: " + ob3.t.isAlive());

        try {
          System.out.println("Waiting for threads to finish.");
          ob1.t.join();
          ob2.t.join();
          ob3.t.join();
        } catch (InterruptedException e) {
          System.out.println("Main thread Interrupted");
        }

        System.out.println("Thread One is alive: " + ob1.t.isAlive());
        System.out.println("Thread Two is alive: " + ob2.t.isAlive());
        System.out.println("Thread Three is alive: " + ob3.t.isAlive());

        System.out.println("Main thread exiting.");
      }
    }

Здесь в мэйне ждем завершения потоков

Код


 ob1.t.join();
 ob2.t.join();
 ob3.t.join();

пока они не остановятся ничего не происходит.

LSD

Дата 13.4.2007, 15:42 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(kkorsakoff @ 13.4.2007, 15:21

)

Это понятно, а на практике?

Код

Runnable target = new Runnable()
{
  public void run()
  {
    try
    {
      FileChannel in = new FileInputStream("DISK1.mdf").getChannel();
      FileChannel out = new FileOutputStream("DISK2.mdf").getChannel();
      try
      {
        in.transferTo(0L, in.size(), out);
      }
      catch(IOException e)
      {
        e.printStackTrace();
      }
      in.close();
      out.close();
    }
    catch(IOException e)
    {
    }
  }
};
Thread thread = new Thread(target);
thread.start();
Thread.sleep(1);
thread.interrupt();

--------------------

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »