java - 如何使用 volatile 标志仅对最后一个 Thread 实例继续运行 run 方法

Question

我使用变量 exit 作为 volatile boolean 标志来暂停 Runnable 中 run 方法的执行。 exit 变量在我的 Activity 类中定义:

private volatile boolean exit = false;

在按钮单击事件上，我使用以下 Runnable 执行新线程的实例化:

class CounterRunnable implements Runnable {

    private Menu menu;

    public CounterRunnable(Menu menu) {
        this.menu = menu;
    }

    @Override
    public void run() {
        int i = 10;
        while(!exit) {
            if (i > 0) {

                final int finalI = i;
                runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        MenuItem counterMenuItem = menu.findItem(R.id.menu_counter);
                        counterMenuItem.setTitle(Integer.toString(finalI));
                    }
                });
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            i--;
            Log.d("Thread name: ", Thread.currentThread().getName() + " i: " + i);
            if (i == 0) { break; }
        }

        scanning = false;
        bluetoothAdapter.stopLeScan(LeScanCallback);
        invalidateOptionsMenu();

    }

    private void stop() {
        exit = true;
    }

    public void start() {
        exit = false;
    }
}

当用户单击扫描按钮时，此类可运行的实例将传递到新的线程实例。该应用程序用于扫描蓝牙设备。 当点击扫描按钮时，它开始从 10 到 0 倒计时。 用户可以选择通过按下另一个停止按钮来停止扫描，每次按下停止然后再次启动时，我都会使用上面定义的可运行实例实例化新的线程实例。 所以这是我实例化新线程的代码:

counterRunnable = new CounterRunnable(menu);
if (!scanning) {
    counterRunnable.stop();
} else {
    counterThread = new Thread(counterRunnable);
    counterThread.start();
    counterRunnable.start();
}

如果用户单击了“扫描”，则“扫描”变量设置为 true；如果用户单击了“停止”，则将 scanning 变量设置为 false。 当用户由于某种原因多次单击“停止”和“扫描”按钮且速度过快时，会生成大量线程。

如何只允许线程的最后一个实例访问 run 方法并终止所有先前的线程？

Answer 1

在启动下一个新线程之前加入当前的 counterThread 怎么样。

当用户点击停止按钮时，我们可以停止并加入当前的 counterThread 来阻止点击事件处理(主线程)，直到当前的 counterThread 停止(仅几毫秒) .

然后我们可以处理传入的开始按钮点击，并在完全停止前一个线程后启动一个新线程。

这是一个示例。

public class MainActivity extends AppCompatActivity implements View.OnClickListener {

    private final static String LOG_TAG = "multithreadmenuupdate";

    private Button mStartButton;
    private Button mStopButton;
    private Menu mMainMenu;
    private CounterThread mCounterThread;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        // Initialize member fields
        mStartButton = findViewById(R.id.startButton);
        mStopButton = findViewById(R.id.stopButton);
        mMainMenu = null;
        mCounterThread = null;

        // Set click listeners for buttons
        mStartButton.setOnClickListener(this);
        mStopButton.setOnClickListener(this);
    }

    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        mMainMenu = menu;
        getMenuInflater().inflate(R.menu.main, mMainMenu);
        // must return true for the menu to be displayed
        return true;
    }

    @Override
    public void onClick(View v) {
        switch(v.getId()) {

            // Start button clicked?
            case R.id.startButton:
                // Thread is already running?
                if(null != mCounterThread && !mCounterThread.isStopped().get()) break;

                mCounterThread = new CounterThread(mMainMenu);
                mCounterThread.start();
                break;

            // Stop button clicked?
            case R.id.stopButton:
                // No thread?
                if(null == mCounterThread) break;

                // Interrupt thread to stop
                mCounterThread.interrupt();
                try {
                    // Wait until current thread stops
                    mCounterThread.join();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                break;
        }
    }

    class CounterThread extends Thread {

        private static final int COUNT_DOWN_START = 10;
        private Menu mMenu;
        // Indicates if thread is being stopped
        // Initially true because the thread is in stopped state
        private final AtomicBoolean mIsStopped = new AtomicBoolean(true);

        public CounterThread(Menu menu) {
            mMenu = menu;
        }

        @Override
        public void run() {
            int countDownValue = COUNT_DOWN_START;

            // Is not stopped?
            while(!mIsStopped.get()) {

                // Count down finished?
                if(countDownValue == 0) break; // stop thread

                // Update menu item with count down value
                updateMenuItem(countDownValue);

                logThreadMenuUpdate(countDownValue);

                // Wait for 1 sec
                try {
                    Thread.sleep(1000); // 1000ms = 1s
                } catch(InterruptedException e) {
                    // Thread has been interrupted to stop?
                    if(mIsStopped.get()) break; // stop thread
                }

                // Count down
                countDownValue--;
            }
        }

        @Override
        public synchronized void start() {
            // Change to false allowing thread to run
            mIsStopped.set(false);
            super.start();
        }

        @Override
        public void interrupt() {
            // Thread is being interrupted to stop
            // Change to true for thread to stop
            mIsStopped.set(true);
            super.interrupt();
        }

        public AtomicBoolean isStopped() {
            return mIsStopped;
        }

        private void updateMenuItem(final int countDownValue) {
            runOnUiThread(new Runnable() {
                @Override
                public void run() {
                    mMenu.findItem(R.id.menu_counter).setTitle(Integer.toString(countDownValue));
                }
            });
        }

        private void logThreadMenuUpdate(int countDownValue) {
            StringBuilder str = new StringBuilder();
            str.append("Thread name: ").append(Thread.currentThread().getName());
            str.append(" - ").append(countDownValue);

            Log.d(LOG_TAG, str.toString());
        }
    }
}

在上面的示例中，我用 CounterThread 替换了您的 CounterRunnable 类。

您还可以找到 MainActivity 实现。

由于我已经添加了 Activity 实现，因此我还将添加 Activity 布局和菜单资源 XML。

res/layout/activity_main.xml

<ConstraintLayout
    android:layout_width="match_parent"
    android:layout_height="match_parent">

    <Button
        android:id="@+id/startButton"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Start"
        app:layout_constraintTop_toTopOf="parent"
        app:layout_constraintBottom_toBottomOf="parent"
        app:layout_constraintStart_toStartOf="parent"
        app:layout_constraintEnd_toStartOf="@id/stopButton" />

    <Button
        android:id="@+id/stopButton"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Stop"
        app:layout_constraintTop_toTopOf="parent"
        app:layout_constraintBottom_toBottomOf="parent"
        app:layout_constraintStart_toEndOf="@id/startButton"
        app:layout_constraintEnd_toEndOf="parent" />

</ConstraintLayout>

res/menu/main.xml

<menu>
    <item
        android:id="@+id/menu_counter"
        android:title="Counter"
        app:showAsAction="always" />
</menu>

这是我的示例 Activity 的屏幕截图。

我使用物理设备进行了测试，通过快速点击并在开始和停止按钮之间切换。看起来效果不错。