如何在 Android 中使用多线程来实现事件处理函数 (SensorListeners)

Question

我的 Android 代码中有一个事件处理机制，可以将传感器值转储到文件中。现在，我正在主 UI 线程中执行此操作，因此 UI 按钮响应速度非常缓慢，我想加快速度。

如何在事件处理函数上使用多线程？我试图这样做：

1. 创建一个全局变量 writeNow。
2. 当传感器值发生变化时，设置 WriteNow = true

3. 在类中创建一个线程，如下所示：

   线程 thread1 = new Thread()  
   {  
     公共无效运行（）  
     {  
       if(writeNow == true)  
         {  
           尝试 
           {  
               fos.write(s.getBytes());  
           } 
           捕获（IOException e） 
           {  
                e.printStackTrace();  
           }  
           现在写=假；  
         }  
     }  
    };  
   

因此，每当 writeNow 为 true 时，它​​将写入文件，然后将 WriteNow 设置为 false。但是，我意识到这不是正确的方法，因为线程将执行一次然后停止执行。当我尝试使用 while(true) 和 wait() 的简单示例时，我发现线程被中断了数百万次。

那么如何将此事件处理机制封装在单个线程中以加速进程呢？

谢谢！

Answer 1

您可以尝试以下方法之一：

1. 看起来您正在尝试让编写器线程始终运行；你能做的就是仅在需要时才生成线程。查看 Android 文档中的示例，了解 处理 UI 中昂贵的操作线程。

   以下是该页面的示例：

   public class MyActivity 扩展 Activity {
   
       [。 。 。 ]
       // 需要回调 UI 线程的处理程序
       最终处理程序 mHandler = new Handler();
   
       // 创建用于发布的可运行程序
       最终 Runnable mUpdateResults = new Runnable() {
           公共无效运行（）{
               updateResultsInUi();
           }
       };
   
       @覆盖
       protected void onCreate(Bundle savingInstanceState) {
           super.onCreate(savedInstanceState);
   
           [。 。 。 ]
       }
   
       受保护的无效startLongRunningOperation（）{
   
           // 关闭一个线程来完成一些我们不应该直接在 UI 线程中完成的工作
           线程 t = 新线程() {
               公共无效运行（）{
                   mResults = doSomethingExpense();
                   mHandler.post(mUpdateResults);
               }
           };
           t.start();
       }
   
       私有无效 updateResultsInUi() {
   
           // 回到 UI 线程——根据 mResults 中的数据更新我们的 UI 元素
           [。 。 。 ]
       }
   }
   

   由于在完成编写后，您看起来并没有在 UI 线程中执行任何操作，因此您实际上不需要为 Handler 操心。但是您可能希望在文件写入后使用它来显示 Toast。

2. 另一方面，如果您仍然想让线程运行，您可以使用 sleep() 并定期唤醒并检查 writeNow 的状态。

   线程 thread1 = new Thread()  
   {  
       公共无效运行（）  
       {  
           而（真）
           {
               if(writeNow == true)  
               {  
                   尝试 
                   {  
                       fos.write(s.getBytes());  
                   } 
                   捕获（IOException e） 
                   {  
                        e.printStackTrace();  
                   }  
   
                   现在写=假；  
               }
   
               尝试
               {
                   线程睡眠（100）； //休眠100毫秒
               }
               捕获（InterruptedException e） 
               {  
                    Log.d('', e.getMessage());  
               }  
           }
       }  
    }; 
   

   请注意，这很快就会变得复杂，如果您的线程在新数据进入时处于休眠状态，并且当它醒来时，甚至已接收到较新的数据并覆盖了先前的字节，您可能会丢失想要写入的字节。您需要某种队列来管理它。

3. 我不确定你用 wait() 做了什么，但这应该也有效，而且事实上，这是解决涉及消费者和生产者问题的方法。这个想法是让你的线程在共享对象（比如你的字节队列）上同步和 wait() ；当有数据可供写入时，第二个线程将在共享对象上调用 notify()，并且写入器线程将被唤醒。然后编写器线程应该写入并重新循环。请查看本教程。

   至于线程的中断，您的线程可能会因多种原因而被中断，这就是为什么确保您检查的条件是好的做法（特别是在使用 wait() 时） 在你调用wait()之前仍然有效，因为你可能因为调用notify()/notifyAll()而被唤醒或者因为中断。

Answer 2

Handler handler = null;

handler = new Handler();

//create another class for and make consrtuctor as u want. so that u can use that effectively.
//for example.                                                      

popupIndex = new IndexThread(handler,head, target,ltp,price,IndexNifty.this,columsView,call);           

popupIndex.setColumnViewexit(columsView);
handler.postDelayed(popupIndex, 300);


//another class
public IntraThread(Handler handler,String script,int target,int ltp,int price,Intraday intraday,TextView columsView,String call){
        super();
        this.target = target;
        this.ltp = ltp;
        this.price = price;     
        this.intraday = intraday;
        this.columsView = columsView;
        this.script= script;
        this.handler= handler;
        this.call= call;
}

public void run(){
// write ur code here....
}