blockingqueue

    0

    1답변

    현재 여러 생성자가 큐에 작업을 추가하는 시나리오가있는 Java 응용 프로그램에서 작업하고 있으며 큐가 비어 있지 않을 때마다 미리 정의 된 속도로 작업을 실행해야합니다. (실행 속도를 유지하기 위해 여러 스레드 사용) 사용 가능한 태스크를 실행 한 후에 실행 프로그램은 대기열에서 다시 사용할 수있는 태스크를 기다려야합니다. 여기서 blockingQueue

    1

    1답변

    동안 무한에의 경우 스레드와 어떻게됩니까 : http://www.blog.pythonlibrary.org/2012/08/01/python-concurrency-an-example-of-a-queue/ 그것은 잘 작동하지만 난 그것에 대해 질문이 있습니다. 스레드의 run 메소드에서 다음을 볼 수 있습니다. def run(self): while Tr

    0

    2답변

    직원을 생성하는 스레드 풀이 있고 직원이 BlockingQueue에서 작업을 가져옵니다. 스레드가 큐에서 take()을 기다립니다. 실행중인 스레드에 대한 스레드 인터럽트 메서드를 명시 적으로 호출하더라도 그들은 여전히 ​​take()을 기다리고 있습니다. blockingqueue public class ThreadPoolGen { static f

    1

    1답변

    다음 방법이 맞는지 알고 싶습니다. 공통의 BlockingQueue에서 작동하는 제작자 및 소비자 스레드가 있습니다. 제작자가 스니퍼 스레드이므로 자동으로 중지되지만 소비자가 생산자 스레드의 상태 (활성/비활성)에 대한 루프로 종료하는 것으로 생각됩니다. 어떤 제안? 감사합니다 -) 메인 스레드에서 : ArrayBlockingQueue<PcapPacket>

    1

    2답변

    put()을 사용하여 스레드에 의해 채워지는 BlockingQueue가 있습니다. 하지만 BlockingQueue를 take()하는 방법에 대해서는 혼란 스럽다. 현재 다음과 같이 구현했습니다. String link; try { while(!(link = links.take()).isEmpty()) { System.out.println

    0

    2답변

    나는 linkedBlockingQueue에 값을 계속 삽입하고이 linkedBlockingQueue를 동시에 가져올 여러 소비자 스레드가 있습니다. 그들이 계속 생각할 수있는 조건은 생산자를위한 깃발이 틀리면 그것이 사실 일 때 취하려고하는 것을 중단 할 때입니다. 그러나 나는 두 번째 스레드가 take() 블록 프로세스에있는 문제를 만났다. 내 프로듀서가

    0

    1답변

    다음은 동일한 유형 인 경우 동일한 유형이 아닌 경우 문제점여러 문자열을 함께 처리하지 않는 문자열 유형에 대해 동일한 executorService를 사용하려고하는 간단한 코드입니다. 스레드는 이전 문자열이 처리 될 때까지 대기해야합니다. 또한이 기능을 구현하기 위해 차단 대기열을 사용할 수 있는지 제안하고 어떻게해야합니까? 생각할 수도 있지만 구현할 수없

    0

    1답변

    시나리오 파일을 서버로 보내는 백그라운드 업로드 대기열이 필요합니다. 대기열은 파일이 대기열 (FIFO)에 푸시 될 때 파일을 순차적으로 보내야합니다. 내 솔루션 var pendingFiles = []; var filesOperation = null; uploadNextAsync = function(file) { var next; i

    0

    1답변

    멀티 스레드 및 Java 동시성 기능에 대한 연습을하고 있습니다. 1 명의 생산자와 4 명의 소비자가 있습니다. 이제 내 질문은 : 생산자가 BlockingQueue에서 생산을 완료했다고 확신 할 때 소비자를 중단시키는 더 현명한 방법이 있습니까? 지금은 대기열에 -1 정수를 사용하고 있지만 매우 기초적으로 보입니다! 는 public class Exerci

    -1

    2답변

    을 : public class Main { static String[] s = { "aaaaaaa", "bbbb", "ccc", "dd" }; public static void main(String[] args) { Watek w = new Watek(0); Watek w1 = new Watek(1); W