如何用java实现runnable

Question

我正在尝试创建一个程序，该程序将自动运行而无需我做任何事情。我对如何在 java 中实现 runnable 有点困惑，所以我可以创建一个将进入睡眠一段时间的线程，然后在睡眠期结束后运行重新运行程序。

public class work {

public static void main(String[] args) throws IOException, InterruptedException {

    work test = new work();
    test.information();

}

private ConfigurationBuilder OAuthBuilder() {
    ConfigurationBuilder cb = new ConfigurationBuilder();
    cb.setOAuthConsumerKey("dy1Vcv3iGYTqFif6m4oYpGBhq");
    cb.setOAuthConsumerSecret("wKKJ1XOPZbxX0hywDycDcZf40qxfHvkDXYdINWYXGUH04qU0ha");
    cb.setOAuthAccessToken("4850486261-49Eqv5mogjooJr8lm86hB20QRUpxeHq5iIzBLks");
    cb.setOAuthAccessTokenSecret("QLeIKTTxJOwpSX4zEasREtGcXcqr0mY8wk5hRZKYrH5pd");
    return cb; 



}

public void information() throws IOException, InterruptedException {

    ConfigurationBuilder cb = OAuthBuilder();
    Twitter twitter = new TwitterFactory(cb.build()).getInstance();
    try {
        User user = twitter.showUser("ec12327");
        Query query = new Query("gym fanatic");
        query.setCount(100);
        query.lang("en");
        String rawJSON =null ;
        String statusfile = null;
        int i=0;

    try {     

                QueryResult result = twitter.search(query);
                for(int z = 0;z<5;z++){
                for( Status status : result.getTweets()){

                    System.out.println("@" + status.getUser().getScreenName() + ":" + status.getText());

                       rawJSON = TwitterObjectFactory.getRawJSON(status);
                         statusfile = "results" + z +".txt";
                        storeJSON(rawJSON, statusfile);

                        i++;

                }
    }


                System.out.println(i);

              }   
              catch(TwitterException e) {         
                System.out.println("Get timeline: " + e + " Status code: " + e.getStatusCode());
                if(e.getErrorCode() == 88){
                    Thread.sleep(900);
                    information();

                }
              }     


    } catch (TwitterException e) {
        if (e.getErrorCode() == 88) {
            System.err.println("Rate Limit exceeded!!!!!!");
            Thread.sleep(90);
            information();
            try {
                long time = e.getRateLimitStatus().getSecondsUntilReset();
                if (time > 0)
                    Thread.sleep(900000);
                    information();
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }
        }
    }
}

 private static void storeJSON(String rawJSON, String fileName) throws IOException {
        FileWriter fileWriter = null;
        try
        {
            fileWriter = new FileWriter(fileName, true);
            fileWriter.write(rawJSON);
            fileWriter.write("\n");
        }
        catch(IOException ioe)
        {
            System.err.println("IOException: " + ioe.getMessage());
        } finally {
            if(fileWriter!=null) {
                fileWriter.close();
            }
        }
    }

}

Answer 1

在 Java 中实现线程有多种选择。

实现Runnable

当一个类实现Runnable接口时，他必须重写run()方法。这个runnable可以传递给Thread的构造函数。然后可以使用start() 方法执行该线程。如果您想让这个线程永远运行并休眠，您可以执行以下操作：

public class HelloRunnable implements Runnable {
    public void run() {
        while(true){
            Thread.sleep(1000);
            System.out.println("Hello from a thread!");
        }
    }

    public static void main(String args[]) {
        (new Thread(new HelloRunnable())).start();
    }
}

扩展Thread

线程本身也有一个run() 方法。扩展线程时，您可以覆盖线程的run() 方法并提供您自己的实现。然后你必须实例化你自己的自定义线程，并以同样的方式启动它。同样，像以前一样，您可以这样做：

public class HelloThread extends Thread {
    public void run() {
        while(true){
            Thread.sleep(1000);
            System.out.println("Hello from a thread!");
        }
    }

    public static void main(String args[]) {
        (new HelloThread()).start();
    }
}

来源：Oracle documentation

Answer 2

在上一个答案的基础上，您需要扩展 Thread 或在 Work 类上实现 Runnable。扩展线程可能更容易。

public class work extends Thread {

    public void run() {
        // your app will run forever, consider a break mechanism
        while(true) {
            // sleep for a while, otherwise you'll max your CPU
            Thread.sleep( 1000 );
            this.information();
        }
    }

    public static void main(String[] args) throws IOException,    InterruptedException {
        work test = new work();
        test.start();
   }

    // ... rest of your class
 }

Answer 3

public static void main(String[] args){
    Thread thread = new Thread(runnable); // create new thread instance
    thread.start(); // start thread
}


public static Runnable runnable = new Runnable(){
    @Override
    public void run(){

      final int DELAY = 500;
      while(true){
          try{
               // Code goes here;
               Thread.sleep(DELAY)
          } catch(Exception e){
              e.printStackTrace();                    
          }

      }

   }

}