Thay thế tốt hơn cho PipedReader/PipedWriter?

Question

Tôi cần có luồng đệm char được đệm, mà tôi viết trong một chuỗi và từ đó tôi đọc trong một chuỗi khác. Right now Tôi đang sử dụng PipedReader và PipedWriter cho nó, nhưng các lớp đó gây ra sự cố hiệu suất: PipedReader thực hiện wait(1000) khi bộ đệm trong của nó trống, khiến ứng dụng của tôi bị trễ rõ ràng.

Sẽ có một số thư viện thực hiện tương tự như PipedReader/PipedWriter, nhưng với hiệu suất tốt hơn? Hoặc tôi sẽ phải thực hiện bánh xe của riêng tôi?

Answer 1

Vấn đề là khi một cái gì đó được ghi vào PipedWriter, nó không tự động thông báo cho PipedReader rằng có một số dữ liệu cần đọc. Khi một người cố gắng đọc PipedReader và bộ đệm trống, PipedReader sẽ lặp lại và chờ sử dụng cuộc gọi wait(1000) cho đến khi bộ đệm có một số dữ liệu.

Giải pháp là gọi PipedWriter.flush() luôn sau khi viết gì đó cho đường ống. Tất cả những gì tuôn ra là gọi notifyAll() trên đầu đọc. Bản sửa lỗi cho mã được đề cập đến looks like this.

(Đối với tôi việc thực hiện PipedReader/PipedWriter trông rất giống với trường hợp tối ưu hóa sớm - tại sao không thông báo cho tất cả trên mỗi lần ghi? Cũng vậy, người đọc chờ đợi trong một vòng lặp hoạt động, thức dậy mỗi giây, thay vì chỉ thức dậy khi có là một cái gì đó để đọc. Mã cũng chứa một số ý kiến ​​todo, mà người đọc/nhà văn phát hiện thread mà nó không phải là đủ tinh vi.)

Vấn đề này cũng xuất hiện trong PipedOutputStream. Trong dự án hiện tại của tôi gọi flush() bằng tay là không thể (không thể sửa đổi số IOUtils.copy() của Commons IO), vì vậy tôi đã sửa nó bằng cách tạo low-latency wrappers cho các lớp ống. Họ làm việc tốt hơn nhiều so với các lớp học ban đầu. :-)

Answer 2

Sẽ khá dễ dàng để bao bọc API luồng char xung quanh BlockingQueue.

Tôi phải nói, tuy nhiên, có vẻ như ngược lại rằng PipedReader sẽ sử dụng bỏ phiếu để chờ dữ liệu. Đây có phải là tài liệu ở đâu đó không, hoặc bạn tự khám phá nó bằng cách nào đó?

Answer 3

Tôi đã triển khai một cái gì đó tương tự một chút và asked a question cho dù bất kỳ ai khác có bất kỳ suy nghĩ và mã thử nghiệm nào tốt hơn.

Answer 4

@Esko Luontola, tôi đã đọc qua mã của bạn trong gói sbt để cố gắng hiểu bạn đang làm gì. Có vẻ như bạn muốn bắt đầu một số Process và chuyển đầu vào cho nó và có kết quả của hành động được thực hiện ở những nơi khác nhau. Điều này có đúng không?

tôi sẽ cố gắng sửa đổi vòng lặp chính trong ReaderToWriterCopier để thay vì làm một read() - một hoạt động ngăn chặn điều đó rõ ràng khi một PipedReader được tham gia bỏ phiếu gây ra - bạn một cách rõ ràng chờ cho Writer-flush. Các tài liệu rõ ràng là flush gây ra bất kỳ Reader s để được thông báo.

Tôi không chắc chắn cách chạy mã của bạn để tôi không thể hiểu sâu hơn về nó. Hi vọng điêu nay co ich.