java - java : Mutithreading & file reading

我想创建其中有两个线程的应用程序
一个线程读取char数据
另一个线程将其打印到控制台
我有以下代码进行interThreadCommunication
(假设文件中包含诸如s t a c k o v e r f l o w之类的数据)
我正在生成输出，如下所示:

From echo int  115 char value s
From echo int  116 char value t
From echo int  97 char value a
From echo int  99 char value c
From echo int  107 char value k
From echo int  111 char value o
From echo int  118 char value v
From echo int  101 char value e
From echo int  114 char value r
From echo int  102 char value f
From echo int  108 char value l
From echo int  111 char value o
From echo int  119 char value w
From echo int  10 char value

代码 :

import java.io.*;
class store
{
    int  i;
    public int get()
    {
        return i;
    }
    public void set(int i)
    {
        this.i=i;
    }
}
public class Main
{
    public static void main(String a[])
    {
        store s=new store();
        Thread th=new Thread(new read(s));
        Thread pr=new Thread(new echo(s));
        th.start();
        pr.start();
    }
}
class echo implements Runnable
{
    store st;
    public echo(store s)
    {
        st=s;
    }
    public void run()
    {
        while(true)
        {
            int t=st.get();
            if(t==-1)
                break;
            if(t!=32)
            {
System.out.println("From echo int  "+t+" char value "+(char)st.get());
            }
            st.set(0);
            try
            {
                //Thread.sleep(200);
                while(true)
                {
                    this.wait();
                    if(st.get()!=0)
                        break;

                }
            }
            catch(Exception r)
            {
            }
        }
    }
}
class read implements Runnable
{
    FileReader fr=null;
    int r;
    store st;
    public read(store s)
    {
        st=s;
    }
    public void run()
    {
        try
        {
            fr=new FileReader("data.txt");
            while(true)
            {
                int r=fr.read();
                st.set(r);
                while(st.get()==0)
                {
                    this.wait();
                }
                if(r==-1)
                    break;
                try
                {
                    Thread.sleep(200);
                }
                catch(Exception re)
                {
                }
            }
            st.set(-1);
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            try
            {
                fr.close();
            }
            catch(Exception e)
            {
                e.printStackTrace();
            }
        }
    }
}

如果我从类sleep()中都删除了read & echo方法，那么我将

From echo int  0 char value
From echo int  0 char value
From echo int  0 char value
.
.
.

我正在使用wait()方法来处理另一个线程。
我做的正确，或者 interThreadCommunication 还有其他方法

最佳答案

您应该考虑使用生产者－消费者模式:
线程A将从文件中读取条目，并将其放入队列中。
线程B将从队列中读取条目并进行打印。
您可以使用blocking queue implementation来确保队列的线程安全。
我还考虑不要将一个字符放入队列中，而应该将一组字符(一个单词或一行)放入队列中，
为了减少入队和出队(由于这些方法是线程安全的，因此它们比非同步方法具有更高的性能损失)。

关于java - java : Mutithreading & file reading，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/13441198/