2

我有一个非常烦人的问题，我无法自己解决这个问题。

我有一个简单的 JavaFX 场景，只有 2 个按钮用于启动和终止线程。在这种情况下，停止操作无关紧要，因为我无法让线程正常工作。actionListener 看起来像：

EDIT1：找出问题所在，它不是特定于线程的，而是针对 TimeServer 的请求，请看这里：回答
感谢大家回答这个问题或阅读这个问题！:)

private FarmAction action = null;

@FXML
void btnStartListener(ActionEvent event) {      
Firefox ff = new Firefox();
ff.startBrowser();

BrowserAction browserAction = new BrowserAction(ff.getDriver(), ff.getJse());
browserAction.loginToGame(user, pass);
ObservableList<AttackCommand> list = (ObservableList<AttackCommand>) Serializer.deserialize(Constants.FILE_NAME_TESTPURPOSE);


if(action == null)
    action = new FarmAction(ff.getDriver(), ff.getJse(), list);

Thread run = new Thread(action);
try {
    run.start();
} catch (Exception e) {
    e.printStackTrace();
} catch (Throwable t) {
    t.printStackTrace();
 }
}

注意：我正在使用 Selenium 框架来自动化网站上的一些点击。

我的 FarmAction 类如下所示：

public class FarmAction implements Runnable{

private WebDriver driver;
private JavascriptExecutor jse;
private ObservableList<AttackCommand> attackList;
private boolean stop = false;

public FarmAction(WebDriver driver, JavascriptExecutor jse, ObservableList<AttackCommand> attackList) {
    this.driver = driver;
    this.jse = jse;
    for(AttackCommand ac : attackList)
    {
        ac.transferFromPropToAttributes();
    }
    this.attackList = attackList;
}


@Override
public void run() {
    ArrayList<Integer> unitIds = Constants.UNIT_ID_LIST_ALL;
    if(!driver.getCurrentUrl().equals(Constants.URL_TESTPURPOSE))
            driver.navigate().to(Constants.URL_TESTPURPOSE);
    int count = 0;
    while(true) { // Just let the Thread run for duration = lifetime of application
        System.out.println(count++); //count how often the thread runs into this while loop before terminating for no reason
        for(AttackCommand ac : attackList) {            
            for(int i = 0; i < unitIds.size(); i ++) {
                int unitKey = unitIds.get(i); // Momentane UnitID der Iteration                 
                if(ac.getUnits().containsKey(unitKey) && ( ac.getTurnBackTime() == 0 ||ac.getTurnBackTime() <= DateUtil.getActualServerTime())) // getActualServerTime is request against the timeserver de.pool.ntp.org
                {
                    String textfieldName = Constants.HASHMAP_TEXTFIELD_NAME_ALL_HTML_PLACE.get(unitKey);
                    WebElement textfield = driver.findElement(By.name(textfieldName));
                    textfield.sendKeys(String.valueOf(ac.getUnits().get(unitKey)));

                    WebElement textfieldCoordinates = driver.findElement(By.name(Constants.TEXTFIELD_NAME_HTML_PLACE_COODRINATESFORTARGET));
                    textfieldCoordinates.sendKeys(StringHelper.getPointAsString(new Point(ac.getXCoordinates(), ac.getYCoordinates())));


                    WebElement submitButton = driver.findElement(By.id(Constants.TA));
                    submitButton.click();

                    WebElement sndAttackSubmitButton = driver.findElement(By.name(Constants.SBM));

                    WebElement span = driver.findElement(By.className(Constants.CLASSNAME_TIME));
                    long duration = Long.parseLong(span.getAttribute(Constants.ATTRIBUTE_DURATION));

                    sndAttackSubmitButton.click();
                    ac.setStartTime(DateUtil.getActualServerTime());
                    ac.setDurationInSeconds(duration*1000);
                    ac.setTurnBackTime(ac.getStartTime()+ac.getDurationInSeconds());
                } 
            }
        }
    }
}}

如您所见，我已将 Thread.start() 方法包装到 Throwables AND Exceptions 的 try-catch 中，但如果线程无故停止，我不会得到任何 Stacktrace。我预计会出现 StackOverFlow 错误，但我什么也没发现。

我的线程正在工作的循环数量非常不同。有时它会在 12 点后停止，有时会在 370 或 59 点后停止。所有值都是示例 - 每次都不同。

你有什么想法我做错了吗？

提前致谢！

4

4 回答 4

1

run()您需要在类的方法中检查异常Thread。

调用start()方法后，创建的线程有自己的栈，与调用方法的主线程的栈不同start()。

因此，线程的方法内部抛出的异常，对于与方法相关的语句run()是不可见的。catchstart()

于 2015-05-28T00:24:36.277 回答
1

正如@Immibis 在评论中提到的那样，捕捉异常是没有意义的，thread.start()因为它会立即返回。

检查异常的一种方法是使用 ，UncaughtExceptionHandler如下所示：

Thread run = new Thread(action);
run.setUncaughtExceptionHandler(
    new Thread.UncaughtExceptionHandler() {
        @Override
        public void uncaughtException(Thread t, Throwable e) {
            e.printStackTrace();
        }
    }
);
run.start();
于 2015-05-28T03:46:43.767 回答
1

好的，伙计们，我已经解决了问题。这不是特定于线程的，对此感到抱歉，但是由于您的回答，我对线程的了解几乎更多:) 感谢大家！

我已将 SystemOuts 放在每条代码线后面，并在 25 次运行和冻结后发现有两个可能的代码线停止工作：

这两个语句都使用了我的DateUtil.getActualServerTime()方法，如下所示：

public static long getActualServerTime() {
    String TIME_SERVER = "de.pool.ntp.org";   
    NTPUDPClient timeClient = new NTPUDPClient();
    InetAddress inetAddress;
    long returnTime = 0;

    try {
        inetAddress = InetAddress.getByName(TIME_SERVER);
        TimeInfo timeInfo = timeClient.getTime(inetAddress);
        returnTime = timeInfo.getMessage().getTransmitTimeStamp().getTime();
    } catch (Exception e) {
        e.printStackTrace();
    } catch (Throwable t) {
        t.printStackTrace();
    }

    return returnTime;
}

我为此使用了 apache.commons.net 库。如果我只是返回一个， Date d = new Date(); return d.getTime(); 我的线程可以正常工作大约 60.000 次循环，直到我手动停止它。

我在这里也没有得到 Exception 或 Throwable 。我会说在特定时间或类似的时间对时间服务器有最大数量的请求。我现在无法在网站上弄清楚。

于 2015-05-28T12:32:22.913 回答
0

我也有同样的问题，我的线程被终止，没有任何异常/可抛出。

我有一个接受套接字的线程（nio，但阻塞模式）。如果套接字以慢速接收请求，但当一次接收大量请求时，线程会停止。

我在linux中更改了一些选项，比如mem [net.ipv4.tcp_rmem, net.core.wmem_default, net.ipv4.tcp_mem]，可能是为了这个？

于 2020-08-14T07:08:45.083 回答