|
@@ -37,10 +37,10 @@ public class URBot {
|
|
Thread queueThread = new Thread(() -> {
|
|
Thread queueThread = new Thread(() -> {
|
|
try {
|
|
try {
|
|
while (true) {
|
|
while (true) {
|
|
|
|
+ cmdDoneSem.acquire();
|
|
var c = cmdq.take();
|
|
var c = cmdq.take();
|
|
sc.writeCmd(c);
|
|
sc.writeCmd(c);
|
|
while (true) {
|
|
while (true) {
|
|
- cmdDoneSem.acquire();
|
|
|
|
if (currentAck.id == c.id && currentAck.message.equals("URWEB_END")) {
|
|
if (currentAck.id == c.id && currentAck.message.equals("URWEB_END")) {
|
|
if (c.cpeeCallback != null) {
|
|
if (c.cpeeCallback != null) {
|
|
ackCPEE(c);
|
|
ackCPEE(c);
|