java - 在主方法中保持扫描仪运行/监听(两个线程)

Question

问题描述:

修改这些文件，以便能够交互式地要求用户提供要显示的广告消息。用户输入要显示的消息并按 ENTER 键。接受用户输入的消息。将用户请求的消息作为广告消息重复显示，每次显示之间暂停 1 秒。

如果用户再次按 ENTER 键(在显示上一条消息时)，程序应询问用户新的(修改后的)消息。用户输入新消息并按 ENTER 键。广告显示现在应该更改为显示新的消息显示，重复显示之间有 1 秒的暂停。当用户输入 n(不区分大小写)时退出程序。

如果我使用以下代码，第一次输入消息时它会正常工作，当我按回车键时，消息的重复打印会被正确中断，并提示我输入新消息。但是，当我单击 Enter 时，重复打印不会中断，因为 main 方法已完成:

import java.util.Scanner;
class Advertisement extends Thread
{
    private boolean done = false;
    String message = "";
    public void run()
    {
        Thread myThread = Thread.currentThread();
        while (!isDone())
        {
            System.out.println("Please enter the advertisement message to be displayed   
                   (enter 'n' to exit):");
            Scanner sc2 = new Scanner(System.in);
            message = sc2.nextLine();
            if (message.equalsIgnoreCase("n"))
            {
                done = true;
                System.out.println("User Stopped the Message Output");
                continue;
            }

            while (!(myThread.isInterrupted()))
            {
                try
                {
                    System.out.print("** " + message + " **");
                    myThread.sleep(1000);
                }
                catch (InterruptedException e)
                {  
                    System.out.println("Exception caught: " + e.getMessage());
                    break;
                }
            }
        }
    }// end of 'run()' ..
    /**
     * @return the done
     */
    public boolean isDone()
    {
        return done;
    }

}

import java.util.Scanner;

public class TestAdvt2
{
    public static void main (String[] args)
    {
        Advertisement advt = new Advertisement();
        advt.start();
        Scanner sc = new Scanner(System.in);
        String str = "start";
        while (!((str.equals(""))))
        {
            str = sc.nextLine();
        }
        advt.interrupt();
    }
}

如果我更改 main 方法以包含 while 循环，则中断将完全停止工作。

import java.util.Scanner;
class TestAdvt
{
    public static void main (String[] args)
    {
        Advertisement advt = new Advertisement();
        advt.start();
        Scanner sc = new Scanner(System.in);
        boolean done = false;
        while (done == false);
        {
            String str = "start";
            while (!((str.equals(""))))
            {
                str = sc.nextLine();
            }
            done = advt.isDone();
            advt.interrupt();
        }
    }
}

任何有关如何实现此功能以便更改消息的建议将不胜感激。

珍妮

更新:

我能够使用您的建议来修复我的代码。我需要做一些清理工作并使用synchronized关键字而不是volatile关键字(这正是老师想要的)。

这是固定代码:

import java.util.Scanner;

/**
*
* @author Jeanne Gaskill
*/

public class Advertisement2 extends Thread
{
    private boolean done = false;
    String message = "";

    public void run() 
    {
        Thread myThread = Thread.currentThread();
        while (true) 
        {
            while (!done) 
            {
                System.out.println("\n\nPlease enter the advertisement message to be displayed "
                    + "(type message or enter 'n' to exit):\n");
                Scanner sc2 = new Scanner(System.in);
                message = sc2.nextLine();
                done = true;
                System.out.println("\n");
                if (message.equalsIgnoreCase("n")) 
                    {
                        System.out.println("User Stopped the Message Output");
                        // Terminating
                        System.exit(0);
                        continue;
                    }
                while (!(myThread.isInterrupted())) 
                {
                    try 
                    {
                        System.out.print("** " + message + " **");
                        Thread.sleep(1000);
                    } 
                    catch (InterruptedException e) 
                    {
                        // System.out.println("Exception caught: " + e.getMessage());
                        done = false;
                        break;

                    }
                }
            }
        }
    }// end of 'run()' ..

    /**
    * @return  done variable
    */
    synchronized public boolean isDone() 
    {
        return done;
    }    

    /**
     * @param done  to set done variable
     */
    synchronized public void setDone(boolean done)
    {
        this.done = done;
    }

}

import java.util.Scanner;

public class TestAdvt
{
    public static void main (String[] args)
    {    
        Advertisement advt = new Advertisement();
        advt.start();
        Scanner sc = new Scanner(System.in);
        while (true) 
        {
            while (advt.isDone()) 
            {
                // main thread is listening
                String str = sc.nextLine();

                // check for new line
                if (str.equals("")) 
                {
                    advt.interrupt();
                }
                advt.setDone(false);
            }
        }
    }

}

@吉格尔

再次感谢!

Answer 1

代码中的一些内容

• 仅当广告线程未监听且仅打印时，您才需要继续监听 main

• 您需要使用 volatile 作为标志变量

• 正确控制旗帜

总结this is the code you need 、格式化、清理，就在你身边