concurrent-queue

2열

1답변

Spliterator를 사용하여 ConcurrentLinkedQueue를 반으로 나누십시오.

저는 ConcurrentLinkedQueue를 가지고 있으며 두 개의 반으로 나눠서 두 개의 개별 스레드가 각각을 처리하도록하고 싶습니다. Spliterator를 사용하여 시도했지만 분할 된 큐를 가져 오는 방법을 이해하지 못합니다. ConcurrentLinkedQueue<int[]> q = // contains a large number of elemen

0열

1답변

동일한 이벤트를 발생시키는 여러 클래스 인스턴스

내 C# 코드의 문제점을 파악하는 데 문제가 있습니다. System.Collections.Concurrent 네임 스페이스에서 ConcurrentQueue 클래스를 사용하는 방법을 배우려고합니다. 이렇게하려면 다른 스레드에서 동일한 클래스의 인스턴스를 두 개 만들고 생성자에게 다른 Listbox 컨트롤을 전달합니다. EventGenerator의 각 클래스

0열

1답변

VB.Net : 스레드에서 ConcurrentQueue의 항목 검색

데이터를 수신하고 ConcurrentQueue 문자열로 푸시하는 한 스레드에서 클래스를 실행 중입니다. Enqueue를 사용하여 데이터를 추가하는 중입니다. 큐 길이가 늘어나 데이터가 올바르게 큐에 있다는 것을 알 수 있습니다. 다른 스레드에서 실행중인 다른 클래스는 FIFO 단위로 각 데이터 조각을 가져와야합니다. 그러나 단순히 아무것도하지 않습니다. D

1열

1답변

Parallel.ConcurrentQueue를 사용하여 목록의 항목을 처리 할 수 있습니까?

병렬 루프를 사용하여 반복 할 수있는 항목이 List<TaskClass> TaskList입니다. 목록의 항목은 TaskClass가 자체 CompareTo(object obj) 메서드를 사용하여 IComparable을 구현할 때 특정 순서로 정렬됩니다. 따라서 우리는 순서대로 행동하는 항목이 필요합니다. 참고 : 순차적으로 완료하지 않아도되며 순차적으로 시작

-1열

1답변

동시 큐 디큐

내가 병렬 다중 스레드 내가 알고 싶은 Parallel.Invoke(action, action, action, action, action, action, action, action, action, action, action, action, action, action, action); 을 동시 큐를 사용하여이 작업 대리자를 만드는 작업 위임 Action

0열

2답변

전역 동시 대기열을 사용하여 두 개의 다른 스레드에서 배열을 변이시킬 때 충돌이 발생하지 않습니다.

아래 코드에서 우리는 두 개의 동시 대기열에 의해 변이 된 가변 배열을가집니다. 동시 대기열은 스레드로부터 안전하지 않으므로이 코드는 이상적으로 중단되어야하지만 예외 나 충돌없이 실행됩니다. 이 동작을 이해하는 데 도움을주십시오. 어떤 도움을 많이 주시면 감사하겠습니다 :-) @interface ViewController() @property(no

2열

2답변

ConcurrentQueue 및 Parallel.ForEach

소스를 가져 오는 데 필요한 URL 목록이있는 ConcurrentQueue가 있습니다. ConcurrentQueue 객체를 입력 매개 변수로 사용하여 Parallel.ForEach를 사용하는 경우 Pop 메서드는 아무 것도 작동하지 않습니다 (문자열을 반환해야 함). MaxDegreeOfParallelism이 4로 설정된 Parallel을 사용하고 있습니다

1열

1답변

대기열에서 읽기 및 쓰기

동시 대기열에 ~ 300 비트 맵을 저장하고 있습니다. 나는 over-tcp 비디오 스트리밍 프로그램을 위해 이것을하고있다. 서버가 느려지면이 큐에 수신 된 비트 맵을 저장합니다 (버퍼링). 이 테스트를 위해 별도의 프로젝트를 만들었지 만 몇 가지 문제가 있습니다. 쓰기 쓰레드가 작동 중일 때 (대기열에 쓰는 동안) 그림 상자는 대기열의 이미지를 보여주고

0열

1답변

ConcurrentQueue는 언제 필요합니까?

나는이 질문이 관련 부탁 해요 : Using events on multithreading socket server I've는이 멀티 스레딩 문제를 방지하기 위해 필요하다 생각 ConcurrentQueue을 구현했습니다. 이 작업을 수행 할 때 Queue 표준과 유일한 차이점은 메서드에 있으며 out 매개 변수를 묻는 것입니다. 나는 이것이 객체를 큐에서 풀

2열

1답변

작업자 스레드 차단 ConcurrentQueue에 항목이 너무 많습니다.

이상한 점은 큐의 내용이 비어있을 때까지 ConcurrentQueue<string>에있는 각 항목을 처리하는 작업자 스레드가 Thread[]입니다. 그 시점에서 나머지 프로그램이 계속됩니다. 이 항목은 WaitSleepJoin 상태에서 모든 스레드가 차단 된 상태에서 약 1500 개의 항목까지 작동하며 대기열에있는 항목을 절대로 처리하지 않습니다. 내 코드