executorservice

0열

2답변

스레드 종료 스레드를 기다리는 중

StopWatch sw = new StopWatch(); sw.start(); ExecutorService executor = Executors.newFixedThreadPool(MYTHREADS); for (int i = 0; i < MYTHREADS; i++) { Runnable worker = new Single

java multithreading executorservice 2017-02-06

---

1열

1답변

응답으로 비동기 동작을 구현하는 방법 Java에서 응답을 반환하는 동안 전자 메일을 보내려면

저는 스프링 응용 프로그램을 사용하고 있으며 REST API를 기반으로하는 SOA 아키텍처를 사용하고 있습니다. 예를 들어 API를 가지고 있습니다 (http://myapp/api/createUser) 그래서 사용자가 생성되면 즉시 사용자에게 이메일을 보내야합니다. 구현했지만 이메일을 보내고 성공/실패, 시간 소모. 스레드에서 전자 메일 부분을 시작하고 백

java spring quartz-scheduler executorservice 2017-02-17

---

2열

3답변

Java ExecutorService 무한 루프 작업

Java에서 데몬 서비스 작업을 쓰려고합니다. 이 서비스는 1 분마다 실행됩니다. 하지만 ExecutorService를 사용하여 구현할 수 없으며 올바른 방법인지 알 수 없습니다. for(;;),없이 break 문 : public void startService() { try { ExecutorService service = Execut

java multithreading executorservice 2017-02-21

---

4열

1답변

CompletableFuture의 whenCompleteAsync 호출에서 Throw 된 RejectedExecutionException을 어떻게 캡처 할 수 있습니까?

다음 예제 코드에서는 완료 가능한 미래 집합의 완료 작업으로 100 밀리 동안 잠을자는 biconsumer을 삽입하고 있습니다. 나는 executorService을 사용하여 whenCompleteAsync 메서드를 사용했습니다. executorService 만 6 출력이 인쇄되는 심지어 내가 100 개 선물을 완료거야하지만, 코어 풀 크기 5, 최대 크기

java java-8 future executorservice completable-future 2017-02-21

---

0열

1답변

RxJava에서 단일 스레드 ExecutorService와 동일한 것은 무엇입니까? 나는 RxJava를 사용하여 해당 설정이 무엇인가 궁금</p> <pre><code>private ExecutorService executor = Executors.newSingleThreadExecutor(); executor.submit(/* ... */); </code></pre> <p>:

내 하나의 장소에 RxJava을 사용하려면 는 ExecutorService 스레드? 는 지금까지 시도하는 것 : private Subject<MyClass> subject = PublishSubject.create() subject.toFlowable(MISSING) .observeOn(Schedulers.single()) .su

java concurrency executorservice rx-java2 2017-02-22

---

0열

3답변

Java 8 고정 스레드 풀이 항상 고정 된 수의 스레드를 생성합니까?

Java 8 고정 스레드 풀 코드가 있습니다. ExecutorService service = Executors.newFixedThreadPool(100); try { for (int i = 0; i < 10; ++i) { service.submit(() -> "In another thread!"); }

java multithreading executorservice 2017-03-01

---

1열

1답변

Java - ScheduledExecutorService를 올바르게 중지하는 방법

ScheduledExecutorService를 사용하여 1 분마다 코드가 실행 중이라고 가정합니다. 이 작업은 startBatch.sh 파일에 의해 트리거됩니다. public class TestScheduledExecutorService { public static void main (String a[]) { ScheduledExecut

java executorservice scheduledexecutorservice 2017-03-02

---

1열

1답변

ExecutorService가 n 개의 스레드와 해당 객체가있는 경우

고정 된 스레드 풀을 사용하는 서비스가 있습니다.이 무거운 작업 중 10 개 이상이 내 서버에 너무 많이 사용되기 때문입니다. Runnable command = new Runnable() { @Override public void run() { MyHeavyClassWithCache myHeavyClassWithCache=

java multithreading executorservice 2017-03-06

---

1열

2답변

다중 스레드 환경에서 각 하위 작업을 병렬로 실행하십시오.

객체를 입력 매개 변수로 사용하여 객체를 가져올 라이브러리에서 작업하고 있습니다. URL을 생성 한 다음 응용 프로그램 서버를 호출합니다. 아파치 http 클라이언트를 사용하여 우리의 라이브러리를 사용하는 고객에게 응답을 돌려 보낸다. 일부 고객은 executeSync 메서드를 호출하여 동일한 기능을 얻게되며 일부 고객은 executeAsync 메서드를 호

java multithreading guava executorservice forkjoinpool 2017-03-09

---

0열

1답변

집행자 서비스 시간 제한 및 계속 실행되지 않습니다

나는 다음과 같은 코드가 있습니다 : 나는 2 분 동안 파일에 트윗을 작성하고 다음 중지 할 트위터 API.I에 액세스 할 수 Twitter4J를 사용하고 def getIndustryData(String[] theIndustries) { PrintWriter printWriter = new PrintWriter(new BufferedWrite

java twitter4j executorservice 2017-03-16

---