threadpool

    1

    1答えて

    Python 2.7でCSVファイルを処理するときに、ThreadPoolとGeneratorを使用するときに問題があります。ここに私のポイントを説明するいくつかのサンプルコードは次のとおりです。 from multiprocessing.dummy import Pool as ThreadPool import time def getNextBatch(): # Reads

    0

    1答えて

    私はSpring ThreadPoolTask​​Schedulerを使用してタスクを実行していますが、私はrun()メソッド内で以下のように同じタスクをスケジューリングしています。そうすることによって、私は現在のタスクが完了した後に次のスケジュールが設定されていることを確認しています。 public class Task implements Runnable{ @Autowired

    -3

    1答えて

    非ブロックhttpクライアントと分離されたスレッドプールで実行されるブロッキングhttpクライアントの使用の違いはパフォーマンス、リソースなどです。後者の場合、スレッドはブロックされますが、分離されたスレッドプールを使用すると、残りのアプリケーションへの影響が減少します。実際の違いはありますか?誰かがこれをクリアできるなら、本当に役に立ちます。

    1

    1答えて

    Java gRPCサーバースレッドは、DEADLINE時間後もまだ実行されています。しかし、gRPCサーバーは、DEADLINE時間が経過して以来、後続のgRPC呼び出しを行わないようにそのスレッドを停止/ブロックしますか? 上記の記述が正しい場合、DEADLINE時間が経過したRedis/DB呼び出しもスレッドを停止/ブロックする方法がありますか?または、DEADLINE時間が過ぎると、スレッド

    -1

    1答えて

    クラスCameraMessageFrameWorkerでいくつかのメッセージを処理するために新しいスレッドを作成したいと思います。これらのクラスのコンストーラーはPartialMessageFrameを取得します。私はこのPartialMessageFrameを新しいprivate変数messageFrameにコピーします。この変数では新しいスレッドを作成したいが、この変数がnullであるため、こ

    0

    1答えて

    Tomcatをさまざまな構成で試しています。私が最初になる前に、それが到着した場合は、2番目の要求がドロップされることを期待していた @Path("/contact") @Slf4j @Singleton public class ContactDropboxService { private ContactDAO contactDAO; private Notifi

    0

    1答えて

    ボタンを持つUniversal Windows Platformアプリケーションをテストしています。一連のボタンを押して作業を終えた後にプログラムを一時停止すると、メインスレッドとワーカースレッドだけが表示されます。私が同じことを十分に速くすると、決して去ることのない追加のワーカースレッドが見つかります。 この残ったワーカースレッドにつながった私の間違いを見つけたいと思いますが、今までのところデバ

    0

    1答えて

    ThreadPoolExecutorのキューの動作を理解しようとしています。以下のプログラムでは、LinkedBlockingQueueを使用すると、一度に1つのタスクしかスレッドプールに送信できません。しかし、LinkedBlockingQueueをSynchronousQueueに置き換えた場合、5つのタスクすべてをプールに瞬時に提出できます。この場合、SynchronousQueueとLin

    0

    1答えて

    私はSpring起動アプリケーションを実行しており、MongoRepositoryを呼び出す複数のスレッドを持っています。しかし、これは奇妙なタイムアウト動作につながります。 これは私のMongoRepositoryです:私が増加した場合 public interface EquipmentRepository extends MongoRepository<Equipment, String>

    2

    1答えて

    私はSystem.Timers.Timerを使用してジョブを処理しています。 サンプルコードは次のとおりです。 private static Timer timer = null; timer = new Timer(INTERVAL_MIN * 1000 * 60); timer.Elapsed += timer_Elapsed; timer.start();