如何在能够暂停/恢复的同时以固定的间隔从线程中获取字符串值



我制作了一个小型swing应用程序供个人使用。这个应用程序连接到互联网,检索文本文件,在jTextArea中显示其内容,并将文本文件保存在本地(在我的硬盘中)。到目前为止还不错。

现在我想以固定的时间间隔(比如每30秒)接收这个文本文件。我可以通过for/while循环(和thread.sleep方法)来实现这一点,但我知道这不是正确的方式,因为它不允许我暂停/恢复接收。我曾尝试使用"线程"one_answers"可调用"来解决我的问题,但未能成功。(我对这些知识不多)

你能指导我如何从线程中收集字符串值吗?我使用Callable/FFuture做的事情对吗?(请查看我的代码)。我应该能够暂停/恢复文本收集。

(在暂停和恢复我的软件时,我会手动编辑文本并将其保存到磁盘上。但我可以处理。)

下面是我尝试过的代码。

public class AmybactUI extends javax.swing.JFrame {
public AmybactUI() {
initComponents();
}
private void initComponents()  { .... }
public static void main(String args[]) throws Exception {
//    (Look and feel setting code here)
java.awt.EventQueue.invokeLater(new Runnable() {
public void run() {
new AmybactUI().setVisible(true);
}
});
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
List<Future<String>> results = executor.invokeAll(Arrays.asList(new GetScore()), 30, TimeUnit.SECONDS);
for (Future<String> result : results) {
if (!result.isCancelled()) {
jTextAreaOnlineScore.append(result.get()+"n");
jTextAreaOnlineScore.setCaretPosition(jTextAreaOnlineScore.getDocument().getLength());
} else {
System.out.println("Task timed out.");
}
executor.shutdown();
}            
}
// Variables declaration - do not modify                     
private javax.swing.ButtonGroup buttonGroup1;
private javax.swing.JButton jButtonSaveSMS;
private javax.swing.JLabel jLabelTitle;
private javax.swing.JMenuBar jMenuBar;
private javax.swing.JMenu jMenuFile;
private javax.swing.JMenu jMenuHelp;
private javax.swing.JMenuItem jMenuItemAbout;
private javax.swing.JMenuItem jMenuItemExit;
private javax.swing.JMenuItem jMenuItemOptions;
private javax.swing.JMenu jMenuTools;
private javax.swing.JPanel jPanel;
private static javax.swing.JRadioButton jRadioButtonOffline;
public static javax.swing.JRadioButton jRadioButtonOnline;
private javax.swing.JScrollPane jScrollPane;
public static javax.swing.JTextArea jTextAreaOnlineScore;
private javax.swing.JTextField jTextFieldCustomSMS;
// End of variables declaration                   
}
class GetScore implements Callable<String> {
public String call() throws Exception {        
Calendar cal = Calendar.getInstance();
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
String nextLine;
String myString = "";
String myTryString;
URL url;
URLConnection urlConn;
InputStreamReader inStream;
BufferedReader buff;
FileWriter fustream;
BufferedWriter bfout;  
try {
//         (some code here which connects to internet and gets my text)
} else {
break;
}
}
bfout.write(myString);
bfout.close();           
} catch(MalformedURLException e) {
System.out.println("Please check the URL:" + e.toString());
} catch(IOException  e1) {
System.out.println("Can't read from the Internet: " + e1.toString());
}
Thread.sleep(4000);
return (""+sdf.format(cal.getTime())+myString);
}
}

实际上,您不需要使用Futures来获得结果。执行以下操作:

  • 将GetScore设为可运行
  • 将TextArea传递给GetScore的构造函数
  • 当执行GetScore.run方法时,请使用textArea.setText方法,或使用SwingUtilities.invokeLater

类似:

SwingUtilities.invokeLater(new Runnable() {
public void run() {
textArea.setText(text);
}
);

相关内容

  • 没有找到相关文章

最新更新