ThreadPoolAdvanceParameter.java 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168
  1. package com.sunzee.thread.advanceparameter;
  2. import android.util.Log;
  3. import com.hboxs.serialport.SerialPortManager;
  4. import com.hboxs.serialport.frame.WriteCommandFrame;
  5. import com.hboxs.serialport.util.HexUtils;
  6. import java.util.concurrent.ScheduledFuture;
  7. import java.util.concurrent.ScheduledThreadPoolExecutor;
  8. import java.util.concurrent.ThreadPoolExecutor;
  9. import java.util.concurrent.TimeUnit;
  10. /**
  11. * 进阶参数线程池
  12. */
  13. public class ThreadPoolAdvanceParameter {
  14. private ScheduledThreadPoolExecutor scheduled;
  15. public String[] getValues() {
  16. return values;
  17. }
  18. private String[] values = new String[6];
  19. private ScheduledFuture<?>
  20. mScheduledFutureD426, mScheduledFutureD427, mScheduledFutureD428,
  21. mScheduledFutureD429, mScheduledFutureD430, mScheduledFutureD431,
  22. mScheduledFutureWrite;
  23. private AdvanceParameterTask
  24. mTaskRunD426, mTaskRunD427, mTaskRunD428, mTaskRunD429,
  25. mTaskRunD430, mTaskRunD431, mTaskRunWrite;
  26. public ThreadPoolAdvanceParameter() {
  27. scheduled = new ScheduledThreadPoolExecutor(6);
  28. //设置线程池的策略 抛弃旧的任务
  29. scheduled.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
  30. }
  31. public boolean isReceive1() {
  32. return isReceive1;
  33. }
  34. public void setReceive1(boolean receive1) {
  35. isReceive1 = receive1;
  36. }
  37. public boolean isReceive2() {
  38. return isReceive2;
  39. }
  40. public void setReceive2(boolean receive2) {
  41. isReceive2 = receive2;
  42. }
  43. public boolean isReceive3() {
  44. return isReceive3;
  45. }
  46. public void setReceive3(boolean receive3) {
  47. isReceive3 = receive3;
  48. }
  49. public boolean isReceive4() {
  50. return isReceive4;
  51. }
  52. public void setReceive4(boolean receive4) {
  53. isReceive4 = receive4;
  54. }
  55. public boolean isReceive5() {
  56. return isReceive5;
  57. }
  58. public void setReceive5(boolean receive5) {
  59. isReceive5 = receive5;
  60. }
  61. public boolean isReceive6() {
  62. return isReceive6;
  63. }
  64. public void setReceive6(boolean receive6) {
  65. isReceive6 = receive6;
  66. }
  67. private boolean isReceive1 = false;
  68. private boolean isReceive2 = false;
  69. private boolean isReceive3 = false;
  70. private boolean isReceive4 = false;
  71. private boolean isReceive5 = false;
  72. private boolean isReceive6 = false;
  73. public void startALLRead() {
  74. mTaskRunD426 = new AdvanceParameterTask(AdvanceParameterThreadType.runD426);
  75. mScheduledFutureD426 = scheduled.scheduleAtFixedRate(mTaskRunD426, 10, 1000, TimeUnit.MILLISECONDS);
  76. mTaskRunD427 = new AdvanceParameterTask(AdvanceParameterThreadType.runD427);
  77. mScheduledFutureD427 = scheduled.scheduleAtFixedRate(mTaskRunD427, 10, 1000, TimeUnit.MILLISECONDS);
  78. mTaskRunD428 = new AdvanceParameterTask(AdvanceParameterThreadType.runD428);
  79. mScheduledFutureD428 = scheduled.scheduleAtFixedRate(mTaskRunD428, 10, 1000, TimeUnit.MILLISECONDS);
  80. mTaskRunD429 = new AdvanceParameterTask(AdvanceParameterThreadType.runD429);
  81. mScheduledFutureD429 = scheduled.scheduleAtFixedRate(mTaskRunD429, 10, 1000, TimeUnit.MILLISECONDS);
  82. mTaskRunD430 = new AdvanceParameterTask(AdvanceParameterThreadType.runD430);
  83. mScheduledFutureD430 = scheduled.scheduleAtFixedRate(mTaskRunD430, 10, 1000, TimeUnit.MILLISECONDS);
  84. mTaskRunD431 = new AdvanceParameterTask(AdvanceParameterThreadType.runD431);
  85. mScheduledFutureD431 = scheduled.scheduleAtFixedRate(mTaskRunD431, 10, 1000, TimeUnit.MILLISECONDS);
  86. }
  87. public void stopAll() {
  88. stopRead(mTaskRunD426, mScheduledFutureD426);
  89. stopRead(mTaskRunD427, mScheduledFutureD427);
  90. stopRead(mTaskRunD428, mScheduledFutureD428);
  91. stopRead(mTaskRunD429, mScheduledFutureD429);
  92. stopRead(mTaskRunD430, mScheduledFutureD430);
  93. stopRead(mTaskRunD431, mScheduledFutureD431);
  94. stopRead(mTaskRunWrite, mScheduledFutureWrite);
  95. }
  96. public void stopReadD426() {
  97. stopRead(mTaskRunD426, mScheduledFutureD426);
  98. }
  99. public void stopReadD427() {
  100. stopRead(mTaskRunD427, mScheduledFutureD427);
  101. }
  102. public void stopReadD428() {
  103. stopRead(mTaskRunD428, mScheduledFutureD428);
  104. }
  105. public void stopReadD429() {
  106. stopRead(mTaskRunD429, mScheduledFutureD429);
  107. }
  108. public void stopReadD430() {
  109. stopRead(mTaskRunD430, mScheduledFutureD430);
  110. }
  111. public void stopReadD431() {
  112. stopRead(mTaskRunD431, mScheduledFutureD431);
  113. }
  114. public static void stopRead(AdvanceParameterTask threadTask, ScheduledFuture<?> scheduledFuture1) {
  115. if (threadTask != null) {
  116. threadTask.setIsRun(false);
  117. }
  118. if (scheduledFuture1 != null) {
  119. scheduledFuture1.cancel(true);
  120. }
  121. }
  122. public void startWrite(String paraAddress, String data) {
  123. mTaskRunWrite = new AdvanceParameterTask(AdvanceParameterThreadType.runWrite, paraAddress, data);
  124. mScheduledFutureWrite = scheduled.scheduleAtFixedRate(mTaskRunWrite, 0, 1000, TimeUnit.MILLISECONDS);
  125. }
  126. public void stopWrite() {
  127. stopRead(mTaskRunWrite, mScheduledFutureWrite);
  128. }
  129. }