sources/net/client/by/lock/a/l.java

   1 package net.client.by.lock.a;
   2
   3 import android.os.Process;
   4 import java.util.concurrent.TimeUnit;
   5 import net.client.by.lock.c.b;
   6
   7 /* compiled from: MyApp */
   8 public class l extends Thread {
   9     final /* synthetic */ k a;
  10
  11     public l(k kVar) {
  12         this.a = kVar;
  13     }
  14
  15     public void run() {
  16         a aVar;
  17         Process.setThreadPriority(-16);
  18         while (!b.a.get()) {
  19             try {
  20                 int size = this.a.l.size();
  21                 if (size > 1) {
  22                     net.client.by.lock.b.e("ReceiverThread", "problem: " + size);
  23                 }
  24                 aVar = (a) this.a.l.poll(200, TimeUnit.MILLISECONDS);
  25                 if (aVar == null) {
  26                     continue;
  27                 }
  28             } catch (InterruptedException e) {
  29                 if (!b.a.get()) {
  30                     e.printStackTrace();
  31                     aVar = null;
  32                 } else {
  33                     return;
  34                 }
  35             }
  36             if (!b.a.get()) {
  37                 this.a.b.a(aVar.a, 0, aVar.b);
  38                 try {
  39                     Thread.sleep(6);
  40                 } catch (InterruptedException e2) {
  41                     return;
  42                 }
  43             } else {
  44                 return;
  45             }
  46         }
  47     }
  48 }