标签：Lock thread2 thread1 lock interrupt import Android

项目地址 https://github.com/webabcd/AndroidDemo
作者 webabcd

一手遮天 Android - 锁和并发处理: Lock 可 interrupt 的 Lock

示例如下:

/concurrent/LockDemo2.java

/**
 * Lock（可 interrupt 的 Lock 的使用）
 *
 * Lock 是一个接口，ReentrantLock 实现了这个接口
 *     lockInterruptibly() - 在线程获取锁的过程中，如果线程被 interrupt() 则抛出 InterruptedException 异常
 */

package com.webabcd.androiddemo.concurrent;

import android.os.SystemClock;
import androidx.appcompat.app.AppCompatActivity;
import android.os.Bundle;
import android.widget.TextView;

import com.webabcd.androiddemo.R;

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class LockDemo2 extends AppCompatActivity {

    private TextView _textView1;

    private Lock _lock = new ReentrantLock();

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

        _textView1 = (TextView) findViewById(R.id.textView1);

        sample();
    }

    /**
     * 本例（使用 lockInterruptibly() 时）的运行结果类似如下：
     * ready（thread1）
     * running（thread1）
     * ready（thread2）
     * interrupted from thread（thread1）
     * interrupted from _lock（thread2）
     *
     * 本例（把 lockInterruptibly() 改成 lock() 时）的运行结果类似如下：
     * ready（thread1）
     * running（thread1）
     * ready（thread2）
     * interrupted from thread（thread1）
     * running（thread2）
     * interrupted from thread（thread2）
     */
    private void sample() {
        Thread thread1 = new Thread(new MyRunnable(), "thread1");
        thread1.setDaemon(true);
        thread1.start();

        Thread thread2 = new Thread(new MyRunnable(), "thread2");
        thread2.setDaemon(true);
        thread2.start();

        // 用于保证上面的 2 个线程都起来了
        SystemClock.sleep(1000);

        thread1.interrupt();
        thread2.interrupt();
    }

    class MyRunnable implements Runnable {

        @Override
        public void run() {
            try {
                execTask();
            } catch (InterruptedException e) {
                // 在通过 lockInterruptibly() 获取锁的过程中，线程被 interrupt() 了
                writeMessage("interrupted from lock");
            }
        }

        private void execTask() throws InterruptedException {
            writeMessage("ready");
            _lock.lockInterruptibly(); // 可以把此处改成 _lock.lock(); 之后再运行一下，以便对比一下区别
            try {
                writeMessage("running");
                Thread.sleep(3000);
                writeMessage("complete");
            } catch (InterruptedException e) {
                writeMessage("interrupted from thread");
            } finally {
                _lock.unlock();
            }
        }
    }

    private void writeMessage(final String message) {
        final String threadName = Thread.currentThread().getName();
        runOnUiThread(new Runnable() {
            @Override
            public void run() {
                _textView1.append(String.format("%s（%s）\n", message, threadName));
            }
        });
    }
}

/layout/activity_concurrent_lockdemo2.xml

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical">

    <TextView
        android:id="@+id/textView1"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content" />

</LinearLayout>

项目地址 https://github.com/webabcd/AndroidDemo
作者 webabcd

标签：Lock,thread2,thread1,lock,interrupt,import,Android
来源： https://www.cnblogs.com/webabcd/p/android_concurrent_LockDemo2.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。