Vertex 3のようなノンブロッキングI/O環境で適切な方法を使用する

Question

現在、morphia（mongoDbの公式Java ORM）をVert.x 3で実装しようとしていますが、すべてのクエリと呼び出しは同期して実行され、Vert.xのイベントループをブロックすることができます。

このクエリを非ブロッキングコードセットにするにはどうすればよいですか。

DBObject query = BasicDBObjectBuilder.start() 
     .add("albums", 
         new BasicDBObject("$elemMatch", 
           new BasicDBObject("$and", new BasicDBObject[] { 
            new BasicDBObject("albumId", albumDto.getAlbumId()), 
            new BasicDBObject("album", 
             new BasicDBObject("$exists", false)) 
       }))) 
     .get(); 

Query<Artist> findQuery = datastore.createQuery(Artist.class, query); 
Artist result = findQuery.get(); 

Answer 1

あなたはVert.xで同期コードを使用する場合は、2つのオプションがあります：

• が
• 垂直方向の労働者を使用しexecuteBlocking閉鎖

Aにお電話をラップ作業員の頂点は常にワーカー・プールからのスレッドで実行されます。ただし、非同期と同期の両方を混在させたい場合は、おそらく2番目のオプションを使用します。 executeBlockinghereをすべて読むことができます。あなたの例を考えれば、それは次のようなものになります：

DBObject query = ... // your definition is probably non blocking 

vertx.executeBlocking(future -> { 
    // Call blocking API that takes a significant amount of time to return 
    Artist result = findQuery.get(); 
    future.complete(result); 
}, res -> { 
    System.out.println("The artist is: " + res.result()); 
});