W jaki sposób można zaimplementować naprawdę asynchroniczny wątek Javy

Question

Mam funkcję, która musi wykonać dwie operacje, jedną, która kończy się szybko, a druga zajmuje dużo czasu. Chcę móc przekazać długotrwałą operację do wątku i nie obchodzi mnie, kiedy wątek się zakończy, ale wątki muszą zostać ukończone. Zaimplementowałem to tak, jak pokazano poniżej, ale moja druga operacja nigdy nie zostanie wykonana, ponieważ funkcja kończy się po wywołaniu start(). Jak mogę zapewnić, że funkcja zwraca, ale drugi wątek operacji również kończy wykonywanie i nie jest zależny od wątku nadrzędnego?

public void someFunction(String data) 
{ 
    smallOperation() 
    SecondOperation a = new SecondOperation(); 
    Thread th = new Thread(a); 
    th.Start(); 
} 

class SecondOperation implements Runnable 
{ 
    public void run(){ 
    // doSomething long running 
} 
} 

Answer 1

public void someFunction(final String data) { 
    shortOperation(data); 
    new Thread(new Runnable() { 
     public void run(){ 
      longOperation(data); 
     } 
    }).start(); 
} 

Jeśli someFunction nazywa, JVM będzie uruchamiać longOperation jeśli

1. nić działa nie zaznaczono jako demon (w powyższym kodzie to nie jest)
2. the longOperation() nie rzuca wyjątku i
3. bez wywołania System.exit() w longOperation()

Answer 2

JVM nie wyjdzie przed zakończeniem wątku. Ten opublikowany kod nawet się nie kompiluje; być może problem leży w twoim prawdziwym kodzie.

Answer 3

JEŚLI twoja druga funkcja nie działa, nie ma to nic wspólnego z powracaniem funkcji. Jeśli coś zadzwoni System.exit() lub jeśli twoja funkcja zgłasza wyjątek, wątek zostanie zatrzymany. W przeciwnym razie będzie działał, dopóki nie zostanie ukończony, nawet jeśli główny wątek zostanie zatrzymany. Można temu zapobiec, ustawiając nowy wątek na demona, ale nie robisz tego tutaj.

Answer 4

Tworzysz prawdziwy asynchroniczny wątek, tworząc drugi wątek w tymczasowym wątku.

(new Thread(new Runnable() { public void run() { 
    (new Thread(new Runnable() { public void run() 
    { 
     /* async thread */ 
    }})).start(); 
}})).start();