アクティブオブジェクト

クラス MyClass { 

    プライベートダブルval = 0.0 ; void doSomething () { val = 1.0 ; }    
    
      
          
    

    void doSomethingElse () { val = 2.0 ; } }  
          
    

クラス MyActiveObject { 

    プライベートdouble val = 0.0 ;プライベートBlockingQueue < Runnable > dispatchQueue = new LinkedBlockingQueue < Runnable > ();    
         

    public MyActiveObject () { new Thread ( new Runnable () { @Override public void run () { try { while ( true ) { dispatchQueue . take (). run (); } } catch ( InterruptedException e ) { // OK、ディスパッチャーを終了します} } } ). start (); }  
            
                    
                
                   
                     
                          
                            
                        
                           
                        
                    
                
            
        
    

    void doSomething ()はInterruptedExceptionをスローします{ dispatchQueue . put ( new Runnable () { @Override public void run () { val = 1.0 ; } } ); }    
          
                
                    
                       
                
            
        
    

    void doSomethingElse ()はInterruptedExceptionをスローします{ dispatchQueue . put ( new Runnable () { @Override public void run () { val = 2.0 ; } } ); } }    
          
                
                    
                       
                
            
        
    

public class MyClass { private double val ; // タスクのコンテナ// 次に実行するリクエストを決定します// asyncMode=true は、ワーカー スレッドがローカル タスク キューを FIFO 順に処理することを意味します// 単一のスレッドのみが内部状態を変更できますprivate final ForkJoinPool fj = new ForkJoinPool ( 1 、ForkJoinPool . defaultForkJoinWorkerThreadFactory 、null 、true ); // アクティブ オブジェクト メソッドの実装public void doSomething () throws InterruptedException { fj . execute (() -> { val = 1.0 ; }); } // アクティブ オブジェクト メソッドの実装public void doSomethingElse () throws InterruptedException { fj . execute (() -> { val = 2.0 ; }); } }