| | |
| | | public class BarcodeThread implements Runnable, ThreadHandler { |
| | | |
| | | private Slave slave; |
| | | private String barcode; |
| | | private String barcode = ""; |
| | | private Socket socket; |
| | | private DataOutputStream dataOutputStream; |
| | | private DataInputStream dataInputStream; |
| | |
| | | connect(); |
| | | while (true) { |
| | | try { |
| | | byte[] read = read(8, 200); |
| | | byte[] read = read(50, 200); |
| | | if (null != read) { |
| | | String s = new String(read); |
| | | if (!Cools.isEmpty(s)) { |
| | |
| | | } |
| | | OutputQueue.BARCODE.offer(jsonObject); |
| | | } |
| | | }else{ |
| | | barcode = ""; |
| | | } |
| | | Thread.sleep(50); |
| | | } catch (SocketTimeoutException ignore) { |
| | | // barcode=""; |
| | | } catch (Exception e) { |
| | | barcode=""; |
| | | // e.printStackTrace(); |
| | | } |
| | | } |