Zugang Faden und führen Sie eine Methode in eine Thread-Klasse

Hier ist mein code:

public class DJ {
    static Thread djThread = new DJPlayThread();

    public static void play(){
        djThread.start();
    }
}

Aber einmal, dass der thread gestartet wird, wie kann ich eine Methode, die in der DJPlayThread Klasse?

Dank.

  • Meinen Sie eigentlich "Wie definiere ich den code, der ausgeführt wird durch den neuen Thread?"
  • Können Sie erklären, was Sie zu tun versuchen? Ich vermute, du hast nicht verstanden, wie Sie Threads verwenden, aber ohne zu wissen, was du versuchst zu erreichen, es ist schwer zu geben, Sie Hinweise.
  • Ja, sorry für die Verwirrung. Ich habe eine Methode namens stop (), die sich in DJPlayThread, dass ich zu rufen Sie von außerhalb des thread-Klasse, wenn das macht keinen Sinn.
  • Die Thread-Klasse hat bereits eine stop-Methode.
  • Diese Methode ist abgeschrieben, und von dem, was ich gelesen habe, unsicher zu verwenden. Ich meine, eine Methode, die ich in der Klasse aufgerufen stop(). Ich kann es umbenennen, was aber, wie stopMusic().
  • Rechts, nur um zu sagen, dass... coming up mit eine Antwort für Sie.

InformationsquelleAutor DannyF247 | 2012-08-20
  1. 5

    Hier ist ein einfaches Beispiel, wie das zu tun, was Sie Fragen:

    public class ThreadControl {

    public static void main(String[] args) {
        MyRunnable myRunnable = new MyRunnable("MyRunnable");
        Thread thread = new Thread(myRunnable);
        thread.setDaemon(true);
        thread.start();

        myRunnable.whoAmI();//call method from within thread

        try {
            Thread.sleep(6000);
        } catch (InterruptedException e) {
        }
        myRunnable.isStopped.set(true);//stop thread
    }

 static class MyRunnable implements Runnable {
        public String threadName;
        public AtomicBoolean isStopped=new AtomicBoolean(false);

        public MyRunnable() {
        }

        public MyRunnable(String threadName) {
            this.threadName = threadName;
        }

        public void run() {
            System.out.println("Thread started, threadName=" + this.threadName + ", hashCode="
                    + this.hashCode());

            while (!this.isStopped.get()) {
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                }
                System.out.println("Thread looping, threadName=" + this.threadName + ", hashCode="
                        + this.hashCode());
            }
        }

        public void whoAmI() {
            System.out.println("whoAmI, threadName=" + this.threadName + ", hashCode="
                    + this.hashCode());
        }

    }

}
    • Ahh danke, ich denke das wird funktionieren. Sobald ich bestätige, dass ich akzeptieren 🙂
    • Durch eine Boolesche diese Weise kann die Arbeit in dem trivialen Fall, aber führt zu subtilen und schwer zu beheben von Fehlern beim Betrieb mit schwerer Last.
    • in allen Formsache, es war eine Probe und die Boolesche hatte nichts mit der Frage zu tun (verwendet) es für die Sauberkeit und für das stoppen des thread
    • Ich denke, es hat alles mit der Frage zu tun. Sollten wir bieten komplette Beispiele. In diesem Fall müssen Sie nur verwenden Sie eine AtomicBoolean, machen isStopped volitile oder Anbieter ein synchronized getter/setter-paar für thread-Sicherheit.
    • Gewinnen Sie :P... bearbeitet meine post
    • Aber "whoAmI" läuft auf dem main thread

    InformationsquelleAutor David Kroukamp
  2. 2
    public class DJ {
    private DJPlayThread djThread = new DJPlayThread();

    public void play() throws InterruptedException {
        djThread.start();

        Thread.sleep(10000);

        djThread.stopMusic();
    }

    public static void main(String[] args){
        try{
            new DJ().play();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

public class DJPlayThread extends Thread{

    private AtomicBoolean running = new AtomicBoolean(true);

    @Override
    public void run() {
        while(running.get()){
            System.out.println("Playing Music");
            try {
                sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void stopMusic(){
        //be careful about thread safety here
        running.set(false);
    }
}

    Sollten ausgedruckt:

    Playing Music 
Playing Music 
Playing Music 
Playing Music 
Playing Music
Playing Music 
Playing Music 
Playing Music 
Playing Music 
Playing Music

    Sehr vorsichtig sein, über die thread-Sicherheit beim Austausch von Informationen zwischen den threads. Es gibt einige seltsame Dinge, die passieren, wenn beim zugreifen auf und ändern von Variablen in thread-Kontexte.

    • +1 gute Idee mit dem Thread-Thema Sicherheit
    • Dank David. Gerade fertig, re-Lektüre, Java Concurrency in der Praxis, so dass Im eingestimmt auf thread-Sicherheit.
    InformationsquelleAutor John Ericksen
Schreibe einen Kommentar