PipedInputStream এবং PipedOutputStream

PipedInputStream এবং PipedOutputStream হল Java I/O প্যাকেজের দুটি ক্লাস যা inter-thread communication বা IPC (Inter-Process Communication) জন্য ব্যবহৃত হয়। এগুলি stream-based communication প্রদান করে এবং এক থ্রেড থেকে অন্য থ্রেডে ডেটা পাঠানোর জন্য ব্যবহৃত হয়। PipedInputStream এবং PipedOutputStream সাধারণত একে অপরের সাথে কাজ করে: PipedOutputStream থ্রেডের মাধ্যমে ডেটা লিখে এবং PipedInputStream সেই ডেটা পড়ে।

এই ক্লাসগুলো মূলত তখন ব্যবহৃত হয় যখন দুইটি থ্রেডের মধ্যে ডেটা আদান-প্রদান করতে হয়।

PipedInputStream এবং PipedOutputStream এর মূল বৈশিষ্ট্য:

1. PipedOutputStream:
   • PipedOutputStream একটি আউটপুট স্ট্রীম যা ডেটা পিপে লিখে। এটি PipedInputStream এর মাধ্যমে ডেটা প্রেরণ করার জন্য ব্যবহৃত হয়।
2. PipedInputStream:
   • PipedInputStream একটি ইনপুট স্ট্রীম যা PipedOutputStream থেকে ডেটা পড়ে। এটি ইনপুট স্ট্রীম থেকে ডেটা গ্রহণ করতে ব্যবহৃত হয়।
3. Inter-Thread Communication (IPC):
   • এক থ্রেড থেকে অন্য থ্রেডে ডেটা পাঠাতে এবং গ্রহণ করতে PipedInputStream এবং PipedOutputStream ব্যবহৃত হয়।
4. Buffering:
   • PipedOutputStream এবং PipedInputStream পিপে ডেটা পাঠানোর জন্য একটি ইনবিল্ট buffer ব্যবহার করে, যার মাধ্যমে ডেটা দ্রুত পাঠানো এবং গ্রহণ করা হয়।

PipedInputStream এবং PipedOutputStream এর উদাহরণ:

এই উদাহরণে, আমরা দুটি থ্রেড তৈরি করব: একটি থ্রেড ডেটা প্রেরণ করবে এবং অন্যটি তা গ্রহণ করবে। PipedOutputStream এবং PipedInputStream ব্যবহার করে ডেটা স্থানান্তর করা হবে।

PipedInputStream এবং PipedOutputStream উদাহরণ:

import java.io.*;

public class PipedStreamExample {
    public static void main(String[] args) {
        // PipedOutputStream এবং PipedInputStream তৈরি করা
        PipedOutputStream out = new PipedOutputStream();
        PipedInputStream in = new PipedInputStream();
        
        try {
            // PipedInputStream এবং PipedOutputStream সংযোগ করা
            in.connect(out);

            // Producer thread যা ডেটা পাঠাবে
            Thread producer = new Thread(new Producer(out));
            
            // Consumer thread যা ডেটা গ্রহণ করবে
            Thread consumer = new Thread(new Consumer(in));
            
            // Producer এবং Consumer থ্রেড চালু করা
            producer.start();
            consumer.start();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // Producer থ্রেড যা PipedOutputStream এ ডেটা পাঠাবে
    static class Producer implements Runnable {
        private PipedOutputStream out;

        public Producer(PipedOutputStream out) {
            this.out = out;
        }

        @Override
        public void run() {
            try {
                String message = "Hello from the Producer!";
                out.write(message.getBytes());  // পিপে ডেটা লিখা
                System.out.println("Producer sent: " + message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    // Consumer থ্রেড যা PipedInputStream থেকে ডেটা গ্রহণ করবে
    static class Consumer implements Runnable {
        private PipedInputStream in;

        public Consumer(PipedInputStream in) {
            this.in = in;
        }

        @Override
        public void run() {
            try {
                byte[] buffer = new byte[1024];
                int length = in.read(buffer); // পিপে থেকে ডেটা পড়া
                String message = new String(buffer, 0, length);
                System.out.println("Consumer received: " + message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

ব্যাখ্যা:

• PipedOutputStream (Producer) একটি থ্রেডের মাধ্যমে ডেটা PipedInputStream (Consumer) এর মাধ্যমে অন্য থ্রেডে পাঠায়।
• connect() মেথড ব্যবহার করে PipedInputStream এবং PipedOutputStream কে একে অপরের সাথে সংযোগ করা হয়েছে।
• Producer থ্রেড ডেটা প্রেরণ করে এবং Consumer থ্রেড সেই ডেটা গ্রহণ করে।

আউটপুট:

Producer sent: Hello from the Producer!
Consumer received: Hello from the Producer!

PipedInputStream এবং PipedOutputStream এর সুবিধা:

1. Inter-Thread Communication:
   • এই ক্লাসগুলি থ্রেডগুলির মধ্যে ডেটা আদান-প্রদান করতে ব্যবহৃত হয়। যখন একাধিক থ্রেডের মধ্যে ডেটা ভাগ করার প্রয়োজন হয়, তখন PipedInputStream এবং PipedOutputStream খুবই কার্যকর।
2. Efficient Data Transfer:
   • পিপে ডেটা স্থানান্তরের সময়, এটি দ্রুত buffered I/O এর মাধ্যমে ডেটা স্থানান্তর করতে সক্ষম।
3. Synchronization:
   • PipedInputStream এবং PipedOutputStream ক্লাসগুলি থ্রেডগুলির মধ্যে সিঙ্ক্রোনাইজড ডেটা স্থানান্তর নিশ্চিত করতে সাহায্য করে।
4. Memory Management:
   • মেমরির মধ্যে buffering এবং stream management সহকারে ডেটা স্থানান্তর করা যায়, যা মেমরি ব্যবস্থাপনা সহজ করে।

PipedInputStream এবং PipedOutputStream এর সীমাবদ্ধতা:

1. Thread Blocking:
   • PipedInputStream এবং PipedOutputStream ব্লকিং স্ট্রীম। এটি অর্থাৎ একটি থ্রেড PipedOutputStream এ ডেটা লেখার আগে অন্য থ্রেড PipedInputStream থেকে ডেটা পড়ে না। তাই থ্রেডগুলির মধ্যে সিঙ্ক্রোনাইজেশন সমস্যা হতে পারে যদি সঠিকভাবে পরিচালনা না করা হয়।
2. Single Producer-Consumer Model:
   • PipedInputStream এবং PipedOutputStream কেবল একটি Producer এবং একটি Consumer এর জন্য ডিজাইন করা হয়েছে। একাধিক প্রযোজক বা গ্রাহককে পরিচালনা করার জন্য অতিরিক্ত পদ্ধতি প্রয়োজন।
3. Limited to Piping Between Two Threads:
   • এই ক্লাসগুলো শুধুমাত্র দুইটি থ্রেডের মধ্যে ডেটা পিপ করতে ব্যবহৃত হয়। একাধিক থ্রেডের মধ্যে ডেটা পিপ করার জন্য কাস্টম ইমপ্লিমেন্টেশন প্রয়োজন।

• PipedInputStream এবং PipedOutputStream ক্লাসগুলি inter-thread communication এর জন্য খুবই কার্যকরী। এগুলি multithreading প্রোগ্রামিংয়ে ডেটা আদান-প্রদান করতে সহায়ক।
• এগুলি buffered streams এর মাধ্যমে ডেটা দ্রুত স্থানান্তর করতে সহায়ক, এবং সহজে এক থ্রেড থেকে অন্য থ্রেডে ডেটা প্রেরণ করা যায়।
• তবে এগুলি কিছু সীমাবদ্ধতা সহ আসে, যেমন শুধুমাত্র দুটি থ্রেডের মধ্যে ডেটা স্থানান্তর করা সম্ভব এবং থ্রেড ব্লকিংয়ের কারণে সিঙ্ক্রোনাইজেশন সমস্যা হতে পারে।

PipedInputStream এবং PipedOutputStream ক্লাসগুলি Java I/O প্যাকেজের অংশ এবং এটি Inter-Thread Communication (ITC) এর জন্য ব্যবহৃত হয়। যখন একটি থ্রেড ডেটা উৎপন্ন করে এবং অন্য একটি থ্রেড সেই ডেটা গ্রহণ করে, তখন PipedInputStream এবং PipedOutputStream খুব কার্যকরীভাবে কাজ করে। এই ক্লাসগুলির মাধ্যমে এক থ্রেডের আউটপুট অন্য থ্রেডের ইনপুটে পাস করা যায়।

এগুলি মূলত Pipes বা Streams এর মধ্যে ডেটা ট্রান্সফার করার জন্য ব্যবহৃত হয়, যা এক বা একাধিক থ্রেডের মধ্যে ডেটা শেয়ার করতে সাহায্য করে। এটি Producer-Consumer Problem এবং Inter-Thread Communication (ITC) এর মতো পরিস্থিতিতে বিশেষভাবে উপকারী।

PipedInputStream এবং PipedOutputStream এর ভূমিকা:

1. PipedInputStream:
   • PipedInputStream ক্লাসটি InputStream এর একটি সাবক্লাস এবং এটি অন্য একটি থ্রেডের PipedOutputStream থেকে ডেটা পড়তে ব্যবহৃত হয়।
   • এটি pipe হিসাবে কাজ করে, যেখানে একটি থ্রেড ডেটা write করে এবং অন্য থ্রেড সেই ডেটা read করে।
2. PipedOutputStream:
   • PipedOutputStream ক্লাসটি OutputStream এর একটি সাবক্লাস এবং এটি অন্য একটি থ্রেডের PipedInputStream এ ডেটা পাঠাতে ব্যবহৃত হয়।
   • এটি pipe এর মাধ্যমে ডেটা লেখার জন্য ব্যবহৃত হয়।

এভাবে, PipedInputStream এবং PipedOutputStream দুটি ক্লাস একে অপরের সাথে যুক্ত হয়ে থ্রেডের মধ্যে ডেটা শেয়ার করার জন্য ব্যবহৃত হয়।

PipedInputStream এবং PipedOutputStream এর সুবিধা:

1. Inter-Thread Communication:
   • দুটি থ্রেডের মধ্যে ডেটা আদান-প্রদান করতে PipedInputStream এবং PipedOutputStream ক্লাসগুলো ব্যবহৃত হয়। একটি থ্রেড একটি স্ট্রীমে ডেটা লিখে এবং অন্য থ্রেড সেই ডেটা পড়ে।
2. Data Transfer Between Threads:
   • যখন দুটি বা তার বেশি থ্রেড একে অপরের সাথে ডেটা শেয়ার করতে চায়, তখন Piped Streams তাদের মধ্যে ডেটা স্থানান্তর করতে সহায়ক।
3. Stream Based Communication:
   • স্ট্রীম ভিত্তিক যোগাযোগ Piped Streams এর মাধ্যমে খুব সহজে করা যায়, যেখানে এক থ্রেড PipedOutputStream তে ডেটা লেখে এবং অন্য থ্রেড PipedInputStream থেকে সেই ডেটা পড়ে।
4. No Intermediate Buffer Required:
   • PipedStreams মধ্যে ডেটা সরাসরি চলে, এর জন্য কোনও মধ্যবর্তী বাফার ব্যবস্থার প্রয়োজন হয় না।

PipedInputStream এবং PipedOutputStream এর উদাহরণ:

এই উদাহরণে, আমরা একটি Producer-Consumer সমস্যা তৈরি করব যেখানে একটি থ্রেড ডেটা উৎপন্ন করবে এবং অন্য থ্রেড সেই ডেটা গ্রহণ করবে।

উদাহরণ: Producer-Consumer Problem

import java.io.*;

class Producer extends Thread {
    private PipedOutputStream pipedOutputStream;

    public Producer(PipedOutputStream pipedOutputStream) {
        this.pipedOutputStream = pipedOutputStream;
    }

    public void run() {
        try {
            String message = "Data from Producer";
            pipedOutputStream.write(message.getBytes());
            System.out.println("Producer sent: " + message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

class Consumer extends Thread {
    private PipedInputStream pipedInputStream;

    public Consumer(PipedInputStream pipedInputStream) {
        this.pipedInputStream = pipedInputStream;
    }

    public void run() {
        try {
            byte[] buffer = new byte[1024];
            int bytesRead = pipedInputStream.read(buffer);
            String message = new String(buffer, 0, bytesRead);
            System.out.println("Consumer received: " + message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public class PipedStreamExample {
    public static void main(String[] args) {
        PipedOutputStream pipedOutputStream = new PipedOutputStream();
        PipedInputStream pipedInputStream = null;

        try {
            pipedInputStream = new PipedInputStream(pipedOutputStream);
        } catch (IOException e) {
            e.printStackTrace();
        }

        Producer producer = new Producer(pipedOutputStream);
        Consumer consumer = new Consumer(pipedInputStream);

        producer.start();
        consumer.start();
    }
}

ব্যাখ্যা:

• এখানে Producer এবং Consumer দুইটি থ্রেড তৈরি করা হয়েছে। Producer থ্রেড PipedOutputStream এর মাধ্যমে ডেটা লিখবে এবং Consumer থ্রেড PipedInputStream এর মাধ্যমে সেই ডেটা পড়বে।
• PipedOutputStream এবং PipedInputStream এর মধ্যে যোগাযোগ করার জন্য pipe ব্যবহার করা হয়েছে।

আউটপুট:

Producer sent: Data from Producer
Consumer received: Data from Producer

PipedInputStream এবং PipedOutputStream এর ব্যবহারিক প্রয়োগ:

1. Producer-Consumer Model:
   • PipedInputStream এবং PipedOutputStream এর মাধ্যমে Producer-Consumer সমস্যা সমাধান করা যায়, যেখানে একজন থ্রেড ডেটা উৎপন্ন করে এবং অন্য থ্রেড সেটি গ্রহণ করে।
2. Data Streaming:
   • একাধিক থ্রেডের মধ্যে ডেটা স্ট্রীমিং করতে এই ক্লাস দুটি ব্যবহৃত হয়। এক থ্রেড একটি স্ট্রীমে ডেটা লিখে এবং অন্য থ্রেড সেই ডেটা পড়ে।
3. Parallel Processing:
   • যখন একাধিক থ্রেডের মধ্যে সমান্তরালভাবে ডেটা প্রক্রিয়াকরণ করতে হয়, তখন Piped Streams খুবই উপকারী। একটি থ্রেড ডেটা উৎপন্ন করতে পারে এবং অন্য থ্রেড সেই ডেটা গ্রহণ করে, ফলে parallel processing সুবিধা পাওয়া যায়।

PipedInputStream এবং PipedOutputStream এর সীমাবদ্ধতা:

1. Single Direction:
   • PipedStreams শুধুমাত্র একে অপরের মধ্যে ডেটা স্থানান্তর করার জন্য ব্যবহৃত হয়। একে একাধিক PipedOutputStream বা PipedInputStream এর মাধ্যমে ডেটা পাঠানো যায় না।
2. Synchronization Requirement:
   • PipedStreams এর মধ্যে ডেটা আদান-প্রদান করতে সঠিক synchronization প্রয়োজন, কারণ multithreading পরিবেশে data race বা deadlock সমস্যা তৈরি হতে পারে।
3. Performance Issues:
   • যদি একাধিক থ্রেডে দ্রুত ডেটা পাঠানোর প্রয়োজন হয়, তবে Piped Streams কিছুটা ধীরগতির হতে পারে, বিশেষত যখন I/O operations বেশি হয়।

• PipedInputStream এবং PipedOutputStream ক্লাসগুলি Inter-Thread Communication (ITC) এর জন্য একটি শক্তিশালী সমাধান প্রদান করে, যেখানে এক থ্রেড একটি পিপে ডেটা লেখে এবং অন্য থ্রেড সেই ডেটা পড়ে।
• এটি Producer-Consumer সমস্যা সমাধানে কার্যকরী এবং parallel data processing এর জন্য উপকারী।
• তবে, এর মধ্যে synchronization এবং single-direction data flow এর সীমাবদ্ধতা থাকতে পারে, যা ব্যবহার করার সময় খেয়াল রাখতে হবে।

এই ক্লাস দুটি Java I/O প্যাকেজের একটি গুরুত্বপূর্ণ অংশ, যা multithreading প্রোগ্রামে ডেটা শেয়ারিং এবং stream-based communication সহজ করে তোলে।

Piped Streams Java I/O প্যাকেজে একটি বিশেষ ধরনের স্ট্রীম যা inter-thread communication এর জন্য ব্যবহৃত হয়। এটি এক থ্রেড থেকে অন্য থ্রেডে ডেটা পাঠানোর জন্য ডিজাইন করা হয়েছে। PipedInputStream এবং PipedOutputStream ক্লাসগুলি ব্যবহার করে এক থ্রেড থেকে অন্য থ্রেডে ডেটা প্রেরণ এবং গ্রহণ করা যেতে পারে।

এই পদ্ধতিটি মূলত Producer-Consumer সমস্যা সমাধানে ব্যবহৃত হয়, যেখানে একটি থ্রেড ডেটা তৈরি (প্রযোজক বা producer) করে এবং অন্য একটি থ্রেড সেটি গ্রহণ (ভোক্তা বা consumer) করে।

Piped Streams এর ধারণা:

1. PipedInputStream: এটি InputStream এর একটি সাবক্লাস, যা producer থ্রেডের দ্বারা লেখা ডেটা consumer থ্রেডের দ্বারা পড়া হয়। এটি byte stream ব্যবহারের জন্য উপযুক্ত।
2. PipedOutputStream: এটি OutputStream এর একটি সাবক্লাস, যা ডেটা consumer থ্রেডের কাছে পাঠানোর জন্য ব্যবহৃত হয়। এটি byte stream ব্যবহারের জন্য উপযুক্ত।
3. PipedReader: এটি Reader এর একটি সাবক্লাস, যা character stream ব্যবহৃত হয়।
4. PipedWriter: এটি Writer এর একটি সাবক্লাস, যা character stream ব্যবহৃত হয়।

Piped Streams এর ব্যবহার:

• Producer-Consumer থ্রেড মডেল ব্যবহৃত হয়, যেখানে একটি থ্রেড producer হিসেবে কাজ করে এবং অন্যটি consumer হিসেবে।
• PipedInputStream এবং PipedOutputStream এর মধ্যে সংযোগ স্থাপন করা হয়। এক থ্রেড PipedOutputStream ব্যবহার করে ডেটা লিখে এবং অন্য থ্রেড PipedInputStream ব্যবহার করে সেই ডেটা পড়ে।
• PipedReader এবং PipedWriter একইভাবে character streams ব্যবহারের জন্য ব্যবহৃত হয়।

Piped Streams উদাহরণ (Inter-Thread Communication):

এই উদাহরণে, একটি থ্রেড Producer ডেটা তৈরি করবে এবং তা PipedOutputStream এর মাধ্যমে পাঠাবে। অন্য একটি থ্রেড Consumer সেই ডেটা PipedInputStream এর মাধ্যমে পড়বে।

Producer এবং Consumer থ্রেড উদাহরণ:

import java.io.*;

class Producer extends Thread {
    private PipedOutputStream pipedOutputStream;

    public Producer(PipedOutputStream pipedOutputStream) {
        this.pipedOutputStream = pipedOutputStream;
    }

    @Override
    public void run() {
        String message = "Hello from Producer Thread!";
        try {
            // পিপেড আউটপুট স্ট্রীমে ডেটা লিখা হচ্ছে
            pipedOutputStream.write(message.getBytes());
            System.out.println("Producer Thread: Message sent");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

class Consumer extends Thread {
    private PipedInputStream pipedInputStream;

    public Consumer(PipedInputStream pipedInputStream) {
        this.pipedInputStream = pipedInputStream;
    }

    @Override
    public void run() {
        try {
            // পিপেড ইনপুট স্ট্রীম থেকে ডেটা পড়া হচ্ছে
            byte[] buffer = new byte[1024];
            int bytesRead = pipedInputStream.read(buffer);
            String message = new String(buffer, 0, bytesRead);
            System.out.println("Consumer Thread: Received message - " + message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

public class PipedStreamExample {
    public static void main(String[] args) {
        try {
            // PipedOutputStream এবং PipedInputStream তৈরি
            PipedOutputStream pipedOutputStream = new PipedOutputStream();
            PipedInputStream pipedInputStream = new PipedInputStream(pipedOutputStream);

            // Producer এবং Consumer থ্রেড তৈরি
            Producer producer = new Producer(pipedOutputStream);
            Consumer consumer = new Consumer(pipedInputStream);

            // থ্রেড শুরু করা হচ্ছে
            producer.start();
            consumer.start();

            // থ্রেডগুলো শেষ হওয়া পর্যন্ত অপেক্ষা করা
            producer.join();
            consumer.join();

        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

ব্যাখ্যা:

1. Producer থ্রেড PipedOutputStream ব্যবহার করে ডেটা লেখে।
2. Consumer থ্রেড PipedInputStream ব্যবহার করে সেই ডেটা পড়ে।
3. PipedOutputStream এবং PipedInputStream এর মধ্যে যোগাযোগ স্থাপন করার জন্য একটি পাইপ তৈরি করা হয়েছে।
4. Producer এবং Consumer থ্রেডগুলি একে অপরের সাথে যোগাযোগের জন্য একটি পাইপ ব্যবহার করছে। Producer ডেটা পাঠিয়ে দেয় এবং Consumer সেই ডেটা গ্রহণ করে।

আউটপুট:

Producer Thread: Message sent
Consumer Thread: Received message - Hello from Producer Thread!

Piped Streams এর সুবিধা:

1. Inter-Thread Communication:
   • Piped Streams এক থ্রেড থেকে অন্য থ্রেডে ডেটা পাঠানোর জন্য খুবই কার্যকরী। এটি producer-consumer প্যাটার্নে কাজ করার জন্য বিশেষভাবে উপযোগী।
2. Real-Time Data Transfer:
   • এটি দুইটি থ্রেডের মধ্যে ডেটা স্থানান্তর দ্রুত এবং লাইভ ভিত্তিতে সম্পাদন করতে পারে।
3. Synchronization:
   • PipedStream এ ডেটা লেখার পরে, অন্য থ্রেড স্বয়ংক্রিয়ভাবে সেই ডেটা পড়তে পারে। এটি একে অপরের মধ্যে সিঙ্ক্রোনাইজেশনের জন্য সহায়ক।

Piped Streams এর সীমাবদ্ধতা:

1. Data Blocking:
   • Piped Streams ব্লকিং প্রাকৃতিক হয়ে থাকে, অর্থাৎ যখন একটি থ্রেড পিপেড আউটপুট স্ট্রীমে ডেটা লেখে না, তখন অন্য থ্রেড পিপেড ইনপুট স্ট্রীমে ডেটা পড়তে পারে না।
2. One-way Communication:
   • Piped Streams সাধারণত one-way communication এর জন্য ব্যবহৃত হয়। এক থ্রেড ডেটা পাঠায় এবং অন্য থ্রেড সেটি পড়ে।
3. Potential Deadlock:
   • যদি আপনি পিপেড ইনপুট এবং আউটপুট স্ট্রীমে একসাথে ডেটা পাঠানোর চেষ্টা করেন এবং পাঠানোর ও পড়ার সঠিক সিঙ্ক্রোনাইজেশন না থাকে, তাহলে deadlock হতে পারে।

• Piped Streams Java-তে inter-thread communication এর জন্য একটি শক্তিশালী টুল।
• PipedOutputStream এবং PipedInputStream ব্যবহার করে থ্রেডগুলির মধ্যে ডেটা পাঠানো এবং গ্রহণ করা যায়।
• এটি producer-consumer model এ কাজ করতে সহায়ক, যেখানে এক থ্রেড ডেটা তৈরি করে এবং অন্যটি সেটি গ্রহণ করে।

Piped Streams ব্যবহারের মাধ্যমে আপনি multi-threaded অ্যাপ্লিকেশনে কার্যকরীভাবে ডেটা স্থানান্তর করতে পারেন, বিশেষত যখন real-time data transfer বা data streaming প্রয়োজন।

Piped Streams হল Java I/O প্যাকেজের অংশ যা এক থ্রেড থেকে অন্য থ্রেডে ডেটা আদান-প্রদান করার জন্য ব্যবহৃত হয়। এগুলি মূলত Inter-Thread Communication (IPC) এর জন্য ব্যবহৃত হয়, যেখানে এক থ্রেড থেকে PipedOutputStream এবং অন্য থ্রেডে PipedInputStream দিয়ে ডেটা পাঠানো হয় এবং পড়া হয়।

PipedInputStream এবং PipedOutputStream একে অপরের সাথে যুক্ত থাকে এবং তারা বাইনারি ডেটা পাঠাতে এবং গ্রহণ করতে পারে। এর মাধ্যমে এক থ্রেড ডেটা প্রেরণ করে এবং অন্য থ্রেড সেই ডেটা গ্রহণ করে।

Piped Streams এর ধারণা:

1. PipedOutputStream:
   • এটি একটি আউটপুট স্ট্রীম হিসেবে কাজ করে যা ডেটা পাইপের মাধ্যমে পাঠায়।
2. PipedInputStream:
   • এটি একটি ইনপুট স্ট্রীম হিসেবে কাজ করে যা পাঠানো ডেটাকে গ্রহণ করে।

এগুলি সাধারনত একে অপরের সাথে connect() মেথডের মাধ্যমে সংযুক্ত থাকে। PipedOutputStream একটি PipedInputStream এর মাধ্যমে ডেটা পাঠাতে পারে এবং PipedInputStream সেই ডেটা পড়ে।

Piped Streams উদাহরণ:

এই উদাহরণে, আমরা একটি Producer থ্রেড তৈরি করব যা PipedOutputStream এর মাধ্যমে ডেটা পাঠাবে, এবং একটি Consumer থ্রেড তৈরি করব যা সেই ডেটা PipedInputStream এর মাধ্যমে গ্রহণ করবে।

Piped Streams Example: Producer and Consumer

import java.io.*;

public class PipedStreamExample {
    public static void main(String[] args) {
        // PipedOutputStream এবং PipedInputStream তৈরি করা
        PipedOutputStream outputStream = new PipedOutputStream();
        PipedInputStream inputStream = new PipedInputStream();

        try {
            // PipedInputStream এবং PipedOutputStream সংযুক্ত করা
            inputStream.connect(outputStream);

            // Producer থ্রেড তৈরি করা
            Thread producerThread = new Thread(new Producer(outputStream));
            // Consumer থ্রেড তৈরি করা
            Thread consumerThread = new Thread(new Consumer(inputStream));

            // থ্রেড চালানো
            producerThread.start();
            consumerThread.start();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // Producer থ্রেড, যা PipedOutputStream এর মাধ্যমে ডেটা পাঠাবে
    static class Producer implements Runnable {
        private PipedOutputStream out;

        public Producer(PipedOutputStream out) {
            this.out = out;
        }

        @Override
        public void run() {
            try {
                String message = "Hello, Consumer!";
                out.write(message.getBytes()); // ডেটা পাঠানো হচ্ছে
                System.out.println("Producer sent: " + message);
                out.close(); // আউটপুট স্ট্রীম বন্ধ করা
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    // Consumer থ্রেড, যা PipedInputStream এর মাধ্যমে ডেটা পড়বে
    static class Consumer implements Runnable {
        private PipedInputStream in;

        public Consumer(PipedInputStream in) {
            this.in = in;
        }

        @Override
        public void run() {
            try {
                byte[] buffer = new byte[1024];
                int length = in.read(buffer); // ডেটা পড়া হচ্ছে
                String message = new String(buffer, 0, length);
                System.out.println("Consumer received: " + message);
                in.close(); // ইনপুট স্ট্রীম বন্ধ করা
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

ব্যাখ্যা:

1. PipedOutputStream এবং PipedInputStream তৈরি করা হয়েছে।
2. connect() মেথড ব্যবহার করে দুটি স্ট্রীমকে একে অপরের সাথে সংযুক্ত করা হয়েছে।
3. একটি Producer থ্রেড তৈরি করা হয়েছে যা PipedOutputStream এর মাধ্যমে "Hello, Consumer!" বার্তাটি পাঠাবে।
4. একটি Consumer থ্রেড তৈরি করা হয়েছে যা PipedInputStream এর মাধ্যমে পাঠানো ডেটা গ্রহণ করবে এবং প্রিন্ট করবে।

আউটপুট:

Producer sent: Hello, Consumer!
Consumer received: Hello, Consumer!

Piped Streams এর সুবিধা:

1. Inter-Thread Communication:
   • PipedStreams থ্রেডের মধ্যে ডেটা আদান-প্রদান করতে সহায়ক। এটি Producer-Consumer প্যাটার্নে ব্যবহৃত হয়, যেখানে একটি থ্রেড ডেটা তৈরি করে এবং অন্য থ্রেড সেই ডেটা গ্রহণ করে।
2. Efficiency:
   • Piped Streams কেবলমাত্র ডেটা প্রেরণের জন্য ব্যবহৃত হয়, সুতরাং এটি দ্রুত এবং memory efficient হয়।
3. Real-Time Data Transfer:
   • এটি একধরণের real-time data transfer তৈরি করে যেখানে একটি থ্রেড ডেটা পাঠাতে শুরু করে এবং অন্য থ্রেড তা গ্রহণ করে, এভাবে থ্রেডগুলো একে অপরের সাথে কাজ করতে পারে।

Piped Streams এর সীমাবদ্ধতা:

1. Blocking I/O:
   • PipedInputStream যখন PipedOutputStream এর ডেটা পাচ্ছে না, তখন এটি blocking I/O এর মতো আচরণ করে, অর্থাৎ এটি wait করবে যতক্ষণ না পিপড আউটপুট স্ট্রীমে ডেটা আসে।
2. Single Producer-Consumer Model:
   • PipedOutputStream কেবল একটি PipedInputStream এর সাথে সংযুক্ত হতে পারে। তাই এটি একমাত্র Producer-Consumer মডেলের জন্য উপযুক্ত।
3. Memory Usage:
   • PipedInputStream এবং PipedOutputStream অনেকটা একটি ফিফো (FIFO) বাফারের মতো কাজ করে, কিন্তু এতে অতিরিক্ত মেমরি ব্যবহৃত হতে পারে যখন অনেক ডেটা পাঠানো বা গ্রহণ করা হয়।

Piped Streams হল একটি কার্যকরী পদ্ধতি যা একাধিক থ্রেডের মধ্যে ডেটা আদান-প্রদান করতে সাহায্য করে। PipedInputStream এবং PipedOutputStream একে অপরের সাথে যুক্ত থাকে এবং একটি থ্রেড output দেয় এবং অন্য থ্রেড সেই input গ্রহণ করে। এই ধরনের স্ট্রীম সাধারণত Producer-Consumer প্যাটার্নে ব্যবহৃত হয়।

যদিও Piped Streams খুবই কার্যকর, তবে এটি blocking I/O এবং single producer-consumer model এর সীমাবদ্ধতা নিয়ে আসে।