android开发如何实现在某个死循环中动态的添加回调函数

在Android开发中，可以通过使用Handler、BroadcastReceiver或者EventBus等方式实现在某个死循环中动态添加回调函数。

1. 使用Handler

在死循环中创建Handler，通过sendMessage()方法发送消息，在Handler的handleMessage()方法中处理消息，实现回调函数的调用。

示例代码：

public class MyThread extends Thread {
    private Handler mHandler;

    public MyThread(Handler handler) {
        mHandler = handler;
    }

    @Override
    public void run() {
        while (true) {
            // do something
            ...
            // 发送消息
            mHandler.sendMessage(mHandler.obtainMessage(0, data));
        }
    }
}

// 在Activity中创建Handler
private Handler mHandler = new Handler() {
    @Override
    public void handleMessage(Message msg) {
        if (msg.what == 0) {
            // 处理消息
            ...
            // 调用回调函数
            callback.onDataReceived((Data)msg.obj);
        }
    }
};

2. 使用BroadcastReceiver

在死循环中发送广播，在BroadcastReceiver中接收广播，实现回调函数的调用。

示例代码：

public class MyThread extends Thread {
    private Context mContext;

    public MyThread(Context context) {
        mContext = context;
    }

    @Override
    public void run() {
        while (true) {
            // do something
            ...
            // 发送广播
            Intent intent = new Intent("com.example.action.DATA_RECEIVED");
            intent.putExtra("data", data);
            mContext.sendBroadcast(intent);
        }
    }
}

// 在Activity中注册BroadcastReceiver
private BroadcastReceiver mReceiver = new BroadcastReceiver() {
    @Override
    public void onReceive(Context context, Intent intent) {
        if ("com.example.action.DATA_RECEIVED".equals(intent.getAction())) {
            // 处理广播
            ...
            // 调用回调函数
            callback.onDataReceived(intent.getParcelableExtra("data"));
        }
    }
};

@Override
protected void onResume() {
    super.onResume();
    registerReceiver(mReceiver, new IntentFilter("com.example.action.DATA_RECEIVED"));
}

@Override
protected void onPause() {
    super.onPause();
    unregisterReceiver(mReceiver);
}

3. 使用EventBus

在死循环中发布事件，在订阅者中订阅事件，实现回调函数的调用。

示例代码：

public class MyThread extends Thread {
    private EventBus mEventBus;

    public MyThread(EventBus eventBus) {
        mEventBus = eventBus;
    }

    @Override
    public void run() {
        while (true) {
            // do something
            ...
            // 发布事件
            mEventBus.post(new DataEvent(data));
        }
    }
}

// 定义事件类
public class DataEvent {
    private Data mData;

    public DataEvent(Data data) {
        mData = data;
    }

    public Data getData() {
        return mData;
    }
}

// 在Activity中注册EventBus
@Override
protected void onResume() {
    super.onResume();
    EventBus.getDefault().register(this);
}

@Override
protected void onPause() {
    super.onPause();
    EventBus.getDefault().unregister(this);
}

// 在Activity中订阅事件
@Subscribe(threadMode = ThreadMode.MAIN)
public void onDataEvent(DataEvent event) {
    // 处理事件
    ...
    // 调用回调函数
    callback.onDataReceived(event.getData());
}

以上三种方式均可以实现在某个死循环中动态添加回调函数，具体使用哪种方式可以根据具体场景和需求选择。