不常见 Handler.post 会导致大量丢帧和崩溃
Infrequent Handler.post's cause huge frame drops and crashes
我有一个简单的线程侦听 UDP 广播以发现我网络上的设备。每当它收到广播时,它都会在 UI 线程上将 Runnable
发布到 Handler
以将设备的 IP 添加到 ArrayList
。最多每 2 秒接收一次数据包。我已经确认这些帖子每 2 秒才会发布一次。
我的应用程序也有一些片段。每当我在片段之间使用 NavController.navigate()
切换时,我都会得到 100-400 帧丢失和 ANR。当我禁用线程,或者甚至只是禁用搜索重复项并将设备添加到 ArrayList
时,帧丢失消失,但搜索和添加时间不到 1 毫秒(根据调试打印)。
我读过很多关于 Handlers
问题的帖子,但其中 none 对我有所帮助。知道为什么我的帖子会导致这么多帧丢失吗?
这是线程的 运行 方法:
public void run(){
try {
DatagramSocket ds = new DatagramSocket(DISCOVERY_PORT);
ds.setSoTimeout(500);
ds.setBroadcast(true);
byte[] rxBuffer = new byte[1024];
DatagramPacket dp = new DatagramPacket(rxBuffer,rxBuffer.length);
while (!this.isInterrupted()) {
try {
ds.receive(dp);
String msg = new String(rxBuffer, 0, dp.getLength());
dp.setLength(rxBuffer.length);
callbackH.post(new Runnable() {
@Override
public void run() {
addGeophone(dp.getAddress().toString(),Integer.parseInt(msg));
}
});
}
catch (SocketTimeoutException e){
continue;
}
}
ds.close();
}
catch(Exception e){
e.printStackTrace();
}
}
以及发布到 UI 线程的 addGeophone 函数:
private static void addGeophone(String ipAddress, int id){
boolean geophoneFound = false;
Geophone g;
//REMOVE BELOW HERE AND EVERYTHING SPEEDS UP.
for (int i = 0; i < geophones.size(); i++){
g = geophones.get(i);
if (g.id == id){
geophoneFound = true;
}
}
if (!geophoneFound) {
geophones.add(new Geophone(ipAddress, id));
}
}
如果从另一个线程执行,看起来 DatagramPacket.getAddress()
需要很长时间。当我将 getAddress
调用移至海报线程时,一切都加快了。
public void run(){
try {
DatagramSocket ds = new DatagramSocket(DISCOVERY_PORT);
ds.setSoTimeout(500);
ds.setBroadcast(true);
byte[] rxBuffer = new byte[1024];
DatagramPacket dp = new DatagramPacket(rxBuffer,rxBuffer.length);
while (!this.isInterrupted()) {
try {
ds.receive(dp);
String msg = new String(rxBuffer, 0, dp.getLength());
dp.setLength(rxBuffer.length);
String ipAddress = dp.getAddress().toString();
callbackH.post(new Runnable() {
@Override
public void run() {
addGeophone(ipAddress,Integer.parseInt(msg));
}
});
}
catch (SocketTimeoutException e){
continue;
}
}
ds.close();
}
catch(Exception e){
e.printStackTrace();
}
}
我有一个简单的线程侦听 UDP 广播以发现我网络上的设备。每当它收到广播时,它都会在 UI 线程上将 Runnable
发布到 Handler
以将设备的 IP 添加到 ArrayList
。最多每 2 秒接收一次数据包。我已经确认这些帖子每 2 秒才会发布一次。
我的应用程序也有一些片段。每当我在片段之间使用 NavController.navigate()
切换时,我都会得到 100-400 帧丢失和 ANR。当我禁用线程,或者甚至只是禁用搜索重复项并将设备添加到 ArrayList
时,帧丢失消失,但搜索和添加时间不到 1 毫秒(根据调试打印)。
我读过很多关于 Handlers
问题的帖子,但其中 none 对我有所帮助。知道为什么我的帖子会导致这么多帧丢失吗?
这是线程的 运行 方法:
public void run(){
try {
DatagramSocket ds = new DatagramSocket(DISCOVERY_PORT);
ds.setSoTimeout(500);
ds.setBroadcast(true);
byte[] rxBuffer = new byte[1024];
DatagramPacket dp = new DatagramPacket(rxBuffer,rxBuffer.length);
while (!this.isInterrupted()) {
try {
ds.receive(dp);
String msg = new String(rxBuffer, 0, dp.getLength());
dp.setLength(rxBuffer.length);
callbackH.post(new Runnable() {
@Override
public void run() {
addGeophone(dp.getAddress().toString(),Integer.parseInt(msg));
}
});
}
catch (SocketTimeoutException e){
continue;
}
}
ds.close();
}
catch(Exception e){
e.printStackTrace();
}
}
以及发布到 UI 线程的 addGeophone 函数:
private static void addGeophone(String ipAddress, int id){
boolean geophoneFound = false;
Geophone g;
//REMOVE BELOW HERE AND EVERYTHING SPEEDS UP.
for (int i = 0; i < geophones.size(); i++){
g = geophones.get(i);
if (g.id == id){
geophoneFound = true;
}
}
if (!geophoneFound) {
geophones.add(new Geophone(ipAddress, id));
}
}
如果从另一个线程执行,看起来 DatagramPacket.getAddress()
需要很长时间。当我将 getAddress
调用移至海报线程时,一切都加快了。
public void run(){
try {
DatagramSocket ds = new DatagramSocket(DISCOVERY_PORT);
ds.setSoTimeout(500);
ds.setBroadcast(true);
byte[] rxBuffer = new byte[1024];
DatagramPacket dp = new DatagramPacket(rxBuffer,rxBuffer.length);
while (!this.isInterrupted()) {
try {
ds.receive(dp);
String msg = new String(rxBuffer, 0, dp.getLength());
dp.setLength(rxBuffer.length);
String ipAddress = dp.getAddress().toString();
callbackH.post(new Runnable() {
@Override
public void run() {
addGeophone(ipAddress,Integer.parseInt(msg));
}
});
}
catch (SocketTimeoutException e){
continue;
}
}
ds.close();
}
catch(Exception e){
e.printStackTrace();
}
}