학교에서 맡은 일 중 하나는이 코드를 수정하는 것입니다. 생산자와 소비자 스레드는 지역 변수를 교대로 증가시키고 인쇄해야하지만 어떻게 수정해야하는지 잘 모릅니다. 생산자와 소비자 스레드가 무한히이를 수행 할 수 있어야합니다. 그러나 실행 파일을 시작하면 임의로 중지됩니다. 누군가이 동작을 설명 할 수 있다면 좋을 것입니다. #include <sys/type
저는 생산자가있는 컨트롤러가 있습니다. @Named
@SessionScoped
public class UserController{
private User user;
//other methods
@Produces
@User
public User produceUser() {
return user;
이 코드를 실행하려했으나 producer.send()가 KeyedMessage 유형을 허용하지 않기 때문에 작동하지 않습니다. kafka.producer.Producer 대신 kafka.javaapi.producer.Producer를 가져 오려고했습니다. 하지만 여전히 작동하지 않는 코드는 다음과 같습니다 package sources;
import jav
나는 여러 개의 생산자를 보유하고 있으며, 각 생산자는 자신의 Blocking queue를 소유하고 있습니다. 각 제작자의 데이터가 독립적으로 처리됩니다 (따라서 별도의 대기열). 내 단일 소비자가 현재 각 대기열을 폴링하고 각각에 대해 시간 초과가 발생합니다. 프로그램은 정상적으로 작동하지만 최적화를 위해 노력하고 있습니다. "폴링"을 좋아하지 않습니다.
Java 응용 프로그램이 디렉토리에서 데이터를 읽고 공통 공유 리소스 대기열에 넣으면 소비자가 이벤트를 사용하여 이벤트의 유효성을 검사하고 데이터베이스에 저장합니다. 디렉토리의 파일을 처리하려고합니다. 응용 프로그램이 다시 시작된 경우에도 한 번만 파일을 다시 처리해야합니다. 중지 된 곳의 파일에서 시작해야합니다. 아무도 도와 줄 수 없습니다.
저는 다양한 방법으로 생산자/소비자 문제를 해결하려고합니다. 필자가 현재 작업하고있는 작업은 세마포어의 down() 및 up() 함수 호출을 보호하기 위해 Peterson의 솔루션과 결합 된 세마포어 구현과 관련됩니다. 문제는, 나는 C에서 일하고 있는데, 세마포어를 만들 수있는 유일한 방법은 down()과 up() 함수 포인터가있는 구조체를 사용하는 것이
DataBase 엔진에 모델을 배포하기 위해 구동 객체 모델 도구 CodeFluentEntities을 사용하고 있습니다. 서버가없는 웹 응용 프로그램에 대한 내 데이터를 저장하기 위해 IndexStDB 또는 Web SQL과 같은 localStorage 데이터베이스 엔진을 사용하려고합니다. 내가 documentation로 보았다하지만이 날 것으로 보인다 조금
iAd Producer를 처음 접했습니다. Apple이 Dashcode를 포기한 것 같아서 제가 정말로 찾고있는 것은 Dashcode를 대체하는 것입니다. 그러나 iAd Producer가 iBooks Author 위젯을 제작할 수있는 것처럼 보일지라도 체크 박스와 라디오 버튼과 같은 몇 가지 기본 객체가 누락 된 것 같습니다. HTML을 해킹하고 jQuer
내 uvm_driver (제작자)가 put 포트를 통해 uvm_component (소비자)와 데이터를 공유하고 있습니다. 공유 항목은 두 개의 데이터 멤버와 getdata 메소드가있는 uvm_transaction 클래스 xfer_data입니다. 드라이버는 getdata를 호출 한 후 즉시 .put 호출을 수행하지만 $ put 문을 통해 소비자 put 작업은
클래스에 대한 생산자 및 소비자 문제로 작업하고 마지막으로 만지기가 어려움. 내가 만나는 문제는 내 뮤텍스 잠금 기능이 내 스레드를 함수에서 잠그지 않는다는 것입니다. 예를 들어 프로그램을 실행하고 매개 변수 2 4 4 7을 전달하면 8 7을 인쇄 한 다음 2 초 후 8 8을 인쇄 한 다음 8 9를 인쇄합니다. 나는 trylock을 사용하고 세마포어를 돌아