root/lanzhouhailiang_one
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:线程阻塞、清除时设备连接

Browse Source
This commit is contained in:
lishuai
2024-08-22 19:07:33 +08:00
parent 3363a5ecb9
commit 1a37c3b38c
7 changed files with 20 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/conveyor/belt_conveyor/BeltConveyorDeviceDriver.java
View File

@@ -240,7 +240,7 @@ public class BeltConveyorDeviceDriver extends AbstractOpcDeviceDriver implements
to_container_no = this.itemProtocol.getContainer_direction();
if (move != last_move) {
if (move != last_move && last_move == 1 && mode > 0) {
requireSucess = false;
clearWrite();
}

2
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_conveyor/box_storage_out_conveyor/BoxStorageOutConveyorDeviceDriver.java
View File

@@ -197,7 +197,7 @@ public class BoxStorageOutConveyorDeviceDriver extends AbstractOpcDeviceDriver i
}
update_instruction_status();
}
if (move != last_move && move == 0 && last_move == 1) {
if (move != last_move && move == 0 && last_move == 1 && mode > 0) {
requireSucess = false;
clearWrite();
}

2
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_conveyor/box_subvolumes_conveyor/BoxSubvolumesConveyorDeviceDriver.java
View File

@@ -198,7 +198,7 @@ public class BoxSubvolumesConveyorDeviceDriver extends AbstractOpcDeviceDriver i
update_instruction_status();
}
if (move != last_move && move == 0 && last_move == 1) {
if (move != last_move && move == 0 && last_move == 1 && mode > 0) {
requireSucess = false;
clearWrite();
}

2
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_conveyor/finished_product_out_with_bind_lable_conveyor/FinishedProductOutBindLableDeviceDriver.java
View File

@@ -202,7 +202,7 @@ public class FinishedProductOutBindLableDeviceDriver extends AbstractOpcDeviceDr
if (move != 0 && task > 0) {
update_instruction_status();
}
if (move != last_move && move == 0 && last_move == 1) {
if (move != last_move && move == 0 && last_move == 1 && mode > 0) {
requireSucess = false;
clearWrite();
}

2
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_conveyor/fold_disc_site/FoldDiscSiteDeviceDriver.java
View File

@@ -199,7 +199,7 @@ public class FoldDiscSiteDeviceDriver extends AbstractOpcDeviceDriver implements
if (move != 0 && task > 0) {
update_instruction_status();
}
if (move != last_move && move == 0 && last_move == 1) {
if (move != last_move && move == 0 && last_move == 1 && mode > 0) {
requireSucess = false;
clearWrite();
}

2
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_conveyor/scanner_weight_conveyor/ConveyorWithScannerWeightDeviceDriver.java
View File

@@ -246,7 +246,7 @@ public class ConveyorWithScannerWeightDeviceDriver extends AbstractOpcDeviceDriv
}
if (move != last_move && move == 0 && last_move == 1) {
if (move != last_move && move == 0 && last_move == 1 && mode > 0) {
requireSucess = false;
clearWrite();
}

28
acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/opc/DeviceExecuteAutoRun.java
View File

@@ -132,23 +132,23 @@ public class DeviceExecuteAutoRun extends AbstractAutoRunnable {
runnable.setIndex(this.runs);
ExecutorService executorService = (ExecutorService) ThreadPoolExecutorUtil.getPoll();
Future<?> future = executorService.submit(runnable);
executorService.submit(runnable);
ScheduledExecutorService scheduler = (ScheduledExecutorService) DtpRegistry.getExecutor("scheduled_pool");
EagerDtpExecutor eagerDtpExecutor = (EagerDtpExecutor) DtpRegistry.getExecutor("scheduled_pool");
OrderedDtpExecutor orderedDtpExecutor = (OrderedDtpExecutor) DtpRegistry.getExecutor("scheduled_pool");
// ScheduledExecutorService scheduler = (ScheduledExecutorService) DtpRegistry.getExecutor("scheduled_pool");
// EagerDtpExecutor eagerDtpExecutor = (EagerDtpExecutor) DtpRegistry.getExecutor("scheduled_pool");
// OrderedDtpExecutor orderedDtpExecutor = (OrderedDtpExecutor) DtpRegistry.getExecutor("scheduled_pool");
// 使用调度器在超时后取消任务
scheduler.schedule(() -> {
//异步任务没有结束
if (!future.isDone()) {
try {
future.get(5, TimeUnit.SECONDS);
} catch (Exception e) {
future.cancel(true);
}
}
}, 1, TimeUnit.MILLISECONDS); // 设置超时时间为10秒
// scheduler.schedule(() -> {
// //异步任务没有结束
// if (!future.isDone()) {
// try {
// future.get(5, TimeUnit.SECONDS);
// } catch (Exception e) {
// future.cancel(true);
// }
// }
// }, 1, TimeUnit.MILLISECONDS); // 设置超时时间为10秒
}
}
}