Verwenden Sie threads über ein RESTful-Web-Service in Java

Ich habe ein problem mit einem RESTful Web Service, ich habe einen client in php aufrufen, einen RESTful-Dienst in Java. In meinem RESTful-Dienst habe ich eine Post-Methode, die ausgeführt wird, eine update-Abfrage so ändern Sie alle Zeilen in einer Tabelle mit 10000 Datensätzen . Ich will zur Benutzung von threads, dies zu tun. Ist es möglich das zu tun?. Bitte helfen Sie mir, ich bin neu in Java. Danke.

OK ich mache das in meinem service-layer: 

for(int i = 0; i < 10; i++)
{
    startRow = i*1000;
    finalRow = i*1000 + 1000;
    Runnable process = new ProcessRecords(startRow , finalRow);
    executor.execute(process);                    
}

//Wait until all threads are finish
while (!executor.isTerminated()) {

}
System.out.println("\n All threads finished");

Wird, und ich nenne diese Klasse (ProcessRecords) um das update auszuführen:

public ProcessRecords (int start, int final)
{
    startRow = start;
    finalRow = final;
}

@Override
public void run(){

    try {

        ConsultUniversity consult = new ConsultUniversity ();
        consult.averangeGrade(startRow, finalRow);

    } catch (Exception ex) {
        Logger.getLogger(Procesos.class.getName()).log(Level.SEVERE, null, ex);
    }
}

Dann in meinem Daten-Schicht mache ich das in meiner Methode "averangeGrade":

 try {
        conn = UniversityConection();//This is my conection

        query = "SELECT * FROM grades LIMIT " + filaInicial + "," + filaFinal;            
        prepStatement = conn.prepareStatement(query);

        rs = prepStatement.executeQuery(query);  

        rsmd = rs.getMetaData();

        while(rs.next())
        {
            averange = (rs.getInt("nFirGrd") + rs.getInt("nSecGrd") + 
                               rs.getInt("nThrGrd"))/3; //the averange of three grades

            query = "UPDATE grades SET nFinGrd = ? WHERE cCodAlu = ?";

            prepStatement = conn.prepareStatement(query);
            prepStatement.setInt(1, averange);
            prepStatement.setString(2, rs.getString("cCodAlu"));

            prepStatement.executeUpdate();

            System.out.println("Record " + rs.getString("cCodAlu") + 
                                       " modified");
        }               

        conn.close(); //close connection    

    }

Dann wenn ich Sie ausführen, meine Kunden, mein Dienst wird das update für die top-Zeilen, 50 Zeilen, dann wieder die Meldung, wie wenn alle Prozesse fertig waren, und ich weiß nicht, warum. Ich denke, dass ist nicht zu warten, bis alle threads fertig sind, aber es ist der code für das, warum ist das passiert?. Bitte helfen Sie mir. Danke.

  • Können Sie das konkretisieren: (1) Was genau meinst du mit "use threads"? (2) welches problem versuchst du zu lösen?
  • Einfach mit einem Faden wird nicht erhöhen Sie die Geschwindigkeit Ihrer Datenbank. Wenn eine RESTful-Aufruf aktualisiert wird jede Zeile in einer Tabelle, vielleicht sollten Sie bei der Reorganisation Ihrer Daten, damit die Tabelle auf einen ausländischen Wert, der muss nur einmal geupdatet.
  • Gut, java-web-Container sind schon multi-threaded. Ich glaube, du bist wahrscheinlich auf der Suche für die Ausführung von asynchronen arbeiten zur Ausführung dieser großen update. Könnten Sie bitte klären, so können wir verstehen, Ihr problem besser?
  • Sie müssen zeigen, was Sie haben recherchiert und versucht, so weit, indem Sie Ihre codes. Jede Antwort auf Ihre aktuelle Frage wird nur mehr Fragen aufwerfen aus/für Sie.
  • Ich leg mehr Informationen in meiner Frage. Danke an Euch alle.
InformationsquelleAutor Erick Rodriguez | 2014-11-11
  1. 3

    Sicher, es ist möglich.
    Sind Sie vertraut mit concurrent-API angeboten, die von Java?

    In einem high-level-Sicht, müssen Sie den code schreiben, dass Griffe, Http POST. In diesem code können Sie instanziieren Sie eine beliebige Anzahl von threads (ein thread pool), und jeder thread der pool macht das update auf eine Untermenge von Zeilen zu aktualisieren.
    Zum Beispiel können Sie beginnen 10 threads, und jeder thread das update machen auf nur 1000 Zeilen.

    Außerdem:

    1. Ich würde das setup der thread-pool beim starten der Anwendung, so dass jedes mal, wenn die POST ausgeführt wird, verwendet es die bereits angelegten pool, und es nicht instanziieren, eine neue zu jeder Zeit (es wäre zu teuer)
    2. Zum zuweisen einer Teilmenge der Zeilen an, die jeder thread haben, müssen Sie auf die GRENZE, und STARTEN Sie sql-Klauseln, die können Sie wählen Sie die Untergruppe. Jeder thread hätte eine andere Abfrage auf Basis dieser 2 Parameter

    Code:

    //instantiate the pool
ExecutorService pool=Executors.newFixedThreadPool(poolSize);
//run the task to execute in parallel, specificying the subset of rows
pool.execute(new UpdateHandler(limit,skip));

//below you find a prototype of the async thread task
class Handler implements Runnable {
   private final int skip;
   private final int limit;
   Handler(int limit, int skip) { ... }

   public void run() {
     //specify the code that runs the query here
   }
 }

    Finden Sie in der Dokumentation hier oder hier
    Hoffe, das hilft.

    • Ja, das war nützlich. Danke, aber ich dennoch keine Auswirkungen haben, denn funktioniert, aber nur für die ersten Zeilen und ich weiß nicht, warum. Ich leg mehr Informationen in meiner Frage. Vielleicht helfen wird. Danke.
    • Wie Sie geschrieben sind, laufen Sie shutdown thread-pool, bevor Sie warten auf das Ende jedes einzelnen Threads. Sie sollten es ausführen, nachdem alle threads beendet Ihre Arbeit.
    • Ja, danke, Ihr war alles Recht, aber wenn ich ausführen meines threads, auch wenn mein thread suppouses fertig sind, wird die while-Schleife nicht beendet. Warum yo denke, dass dies passiert ist?
    • Die while-Schleife? In die threads oder die, während deren Zustand isTerminated() ?
    InformationsquelleAutor Giovanni Bitliner
Schreibe einen Kommentar