スレッド作成リスナー

Question

スレッド作成リスナーをJavaで記述することはできますか？例えばaopを使って？

私のアプリケーションがスレッドを作成した場合、自分のテーブル、コンテナなどにこのオブジェクトを登録したいと思うということです。

Answer 1

私は、これはAOP（例えば、AspectJの）で可能になると思います。ただし、アスペクトコンパイラでJDKクラスを再コンパイルできる場合を除き、独自のThreadとThreadGroup/Executorの型を作成する必要があります。スレッドの起動時に登録する場合は、スレッドのstartメソッドにポイントカットを定義し、スレッドオブジェクトの作成時に登録する場合は、プールのcreateThreadにポイントカットを定義します。そして、あなたがしたいのですが何をしてアドバイスを使用することができますすべてのスレッドがThread.startで開始され ので、その方法のためのポイントカットを記述します。

---

次は、アスペクトコンパイラでJDKを再コンパイルする場合にのみ機能します。もちろん、これは完璧ではない。 cachedThreadPoolエグゼキュータは各タスクの新しいスレッドを開始しないかもしれませんが、Thread.startではなくRunnable.runとCallable.callにポイントカットを登録すると、十分かもしれません。

Answer 2

私は、JVM上のすべての実行中スレッドを継続的に一覧表示するスレッドを作成します。
新しいスレッドが出現したことを通知するたびに、どちらの方法でもコードのクラスを通知します。

1. Get a List of all Threads currently running in Java

2. Listing All Running Threads

=========：ここ

は、現在JVM上で実行されているすべてのスレッドの一覧を表示する方法についていくつかのリンクがあります===

開始コード：

ThreadCreationListener.java

public interface ThreadCreationListener { 
    public void onThreadCreation(Thread newThread); 
} 

ThreadCreationMonitor.java

public class ThreadCreationMonitor extends Thread { 
    private List<ThreadCreationListener> listeners; 
    private boolean canGo; 

    public ThreadCreationMonitor() { 
     listeners = new Vector<ThreadCreationListener>();//Vector class is used because many threads may use a ThreadCreationMonitor instance. 
     canGo = true; 
     // Initialize the rest of the class here... 
    } 

    // Most important methods 
    public void addListener(ThreadCreationListener tcl) { 
     listeners.add(tcl); 
    } 

    public void removeListener(ThreadCreationListener tcl) { 
     listeners.remove(tcl); 
    } 

    public void run() { 
     List<Thread> runningThreads; 
     List<Thread> lastRunningThreads; 

     while(canGo) { 
      // Step 1 - List all running threads (see previous links) 
      // runningThreads = ... 

      // Step 2 - Check for new threads and notify all listeners if necessary 
      if (runningThreads.removeAll(lastRunningThreads)==true) { 
       for(Thread t : runningThreads) { 
        for(ThreadCreationListener tcl : listeners) { 
         tcl.onThreadCreation(t);//Notify listener 
        } 
       } 
      } 
     } 
    } 

    public void shutdown() { 
     canGo = false; 
    } 

}

MyThreadInfoConsumer.java

public class MyThreadInfoConsumer implements ThreadCreationListener { 
    public void onThreadCreation(Thread newThread) { 
     // Process here the notification... 
    } 
} 

Main.java

public class Main { 
    public static void main(String[] args) { 
     ThreadCreationMonitor tcm = new ThreadCreationMonitor(); 
     tcm.start(); 

     MyThreadInfoConsumer myTIC = new MyThreadInfoConsumer(); 
     tcm.addListener(myTIC); 

     // rest of your code... 
     // Don't forget to call tcm.shutdown() when exiting your application ! 
    } 
} 

Answer 3

おそらくThreadGroupが必要なものです。すべてのスレッドはThreadGroupのメンバーであり、新しいスレッドを開始すると、デフォルトではそのグループと同じグループに追加されます。

理論的には、スレッドがグループに追加または削除されたときに通知される可能性のある（推奨されない）サブクラスです。

このグループのスレッドをポーリングするか、すべてのスレッドをポーリングする方が良い解決策です。