|  |  | 
 |  |  |  | 
 |  |  | import com.core.common.Cools; | 
 |  |  | import com.zy.core.cache.SlaveConnection; | 
 |  |  | import com.zy.core.enums.SlaveType; | 
 |  |  | import com.zy.core.properties.SlaveProperties; | 
 |  |  | import com.zy.core.thread.CrnThread; | 
 |  |  | import com.zy.core.thread.DevpThread; | 
 |  |  | 
 |  |  |  | 
 |  |  |     private void initThread(){ | 
 |  |  |         // 初始化堆垛机线程 | 
 |  |  |         if (!Cools.isEmpty(slaveProperties.getCrn())) { | 
 |  |  |             for (Slave crn : slaveProperties.getCrn()) { | 
 |  |  |                 CrnThread crnThread = new CrnThread(crn); | 
 |  |  |                 new Thread(crnThread).start(); | 
 |  |  |                 SlaveConnection.put(ThreadHandler.CRN_PREFIX + crn.getId(), crnThread); | 
 |  |  |             } | 
 |  |  |         for (Slave crn : slaveProperties.getCrn()) { | 
 |  |  |             CrnThread crnThread = new CrnThread(crn); | 
 |  |  |             new Thread(crnThread).start(); | 
 |  |  |             SlaveConnection.put(SlaveType.Crn, crn.getId(), crnThread); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         // 初始化站点线程 | 
 |  |  |         if (!Cools.isEmpty(slaveProperties.getDevp())) { | 
 |  |  |             for (Slave devo : slaveProperties.getDevp()) { | 
 |  |  |                 DevpThread devpThread = new DevpThread(devo); | 
 |  |  |                 new Thread(devpThread).start(); | 
 |  |  |             } | 
 |  |  |         for (Slave devo : slaveProperties.getDevp()) { | 
 |  |  |             DevpThread devpThread = new DevpThread(devo); | 
 |  |  |             new Thread(devpThread).start(); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |     } |