{"id":2014,"date":"2011-07-15T13:41:41","date_gmt":"2011-07-15T04:41:41","guid":{"rendered":"http:\/\/192.168.0.71:9090\/?p=2014"},"modified":"2011-07-15T13:41:41","modified_gmt":"2011-07-15T04:41:41","slug":"net-command-queue-%ea%b5%ac%ed%98%84","status":"publish","type":"post","link":"https:\/\/talsu.net\/?p=2014","title":{"rendered":".NET &#8211; Command Queue \uad6c\ud604"},"content":{"rendered":"<p>\uc990\uaca8\uc4f0\ub294 Command Queue \ubc29\uc2dd.<\/p>\n<p>Polling \ud558\ub294 Thread\ub97c \ub530\ub85c \ub450\uc9c0 \uc54a\ub294\ub2e4.<\/p>\n<h3>Command Interface<\/h3>\n<pre class=\"lang:c# decode:true\">\ninterface IExecutable\n{\n    void Execute();\n}\n<\/pre>\n<p><\/p>\n<h3>Command Executer<\/h3>\n<pre class=\"lang:c# decode:true\">\n\/\/\/ <summary>\n\/\/\/ The executer with queue.\n\/\/\/ <\/summary>\ninternal class ExecuterWithQueue\n{\n    \/\/\/ <summary>\n    \/\/\/   The is executing.\n    \/\/\/ <\/summary>\n    private bool isExecuting;\n\n    \/\/\/ <summary>\n    \/\/\/   The queue.\n    \/\/\/ <\/summary>\n    private ConcurrentQueue<iexecutable> queue;\n\n    \/\/\/ <summary>\n    \/\/\/ Gets Queue.\n    \/\/\/ <\/summary>\n    private ConcurrentQueue<iexecutable> Queue\n    {\n        get\n        {\n            if (this.queue == null)\n            {\n                this.queue = new ConcurrentQueue<iexecutable>();\n\n                Logger.Write(\"Queue\", string.Format(\"{0} Queue Created.\", \"IExecutable\"), TraceEventType.Verbose);\n            }\n\n            return this.queue;\n        }\n    }\n\n    \/\/\/ <summary>\n    \/\/\/ The enqueue.\n    \/\/\/ <\/summary>\n    \/\/\/ <param name=\"command\">\n    \/\/\/ The command.\n    \/\/\/ <\/param>\n    public void Enqueue(IExecutable command)\n    {\n        Queue.Enqueue(command);\n\n        Logger.Write(\"Enqueue\", string.Format(\"{0} Queue length : {1}\", \"IExecutable\", Queue.Count), TraceEventType.Verbose);\n\n        DequeueAndExecute();\n    }\n\n    \/\/\/ <summary>\n    \/\/\/ The dequeue and execute.\n    \/\/\/ <\/summary>\n    private void DequeueAndExecute()\n    {\n        if (this.isExecuting)\n        {\n            return;\n        }\n\n        IExecutable command;\n\n        if (!Queue.TryDequeue(out command))\n        {\n            return;\n        }\n\n        try\n        {\n            this.isExecuting = true;\n\n            command.Execute();\n        }\n        catch (Exception ex)\n        {\n            Logger.Write(ex);\n        }\n        finally\n        {\n            this.isExecuting = false;\n\n            DequeueAndExecute();\n        }\n    }\n}\n<\/pre>\n<p>\ube44\ub3d9\uae30 \uc791\uc5c5 \ud050<\/p>\n<pre class=\"lang:c# decode:true\">\ninternal delegate void AsyncJob(Action callback);\n\n\/\/\/ <summary>\n\/\/\/   The Async job queue.\n\/\/\/ <\/summary>\ninternal class AsyncJobQueue\n{\n    \/\/\/ <summary>\n    \/\/\/   The is executing.\n    \/\/\/ <\/summary>\n    private bool _isExecuting;\n\n    \/\/\/ <summary>\n    \/\/\/   The queue.\n    \/\/\/ <\/summary>\n    private ConcurrentQueue<asyncJob> _jobQueue;\n\n    \/\/\/ <summary>\n    \/\/\/   Gets Queue.\n    \/\/\/ <\/summary>\n    private ConcurrentQueue<asyncJob> JobQueue\n    {\n        get\n        {\n            if (_jobQueue == null)\n            {\n                _jobQueue = new ConcurrentQueue<asyncJob>();\n\n                Console.WriteLine(\"{0} Queue Created.\", \"IExecutable\");\n            }\n\n            return _jobQueue;\n        }\n    }\n\n    \/\/\/ <summary>\n    \/\/\/   The enqueue.\n    \/\/\/ <\/summary>\n    \/\/\/ <param name=\"job\"> The job. <\/param>\n    public void Enqueue(AsyncJob job)\n    {\n        JobQueue.Enqueue(job);\n\n        DequeueAndExecute();\n    }\n\n    \/\/\/ <summary>\n    \/\/\/   The dequeue and execute.\n    \/\/\/ <\/summary>\n    private void DequeueAndExecute()\n    {\n        if (_isExecuting)\n        {\n            return;\n        }\n\n        AsyncJob job;\n\n        if (!JobQueue.TryDequeue(out job))\n        {\n            return;\n        }\n\n        _isExecuting = true;\n\n        ThreadPool.QueueUserWorkItem(j => ((AsyncJob) j)(Callback), job);\n    }\n\n    \/\/\/ <summary>\n    \/\/\/   Job finished callback\n    \/\/\/ <\/summary>\n    public void Callback()\n    {\n        _isExecuting = false;\n        DequeueAndExecute();\n    }\n}\n<\/pre>\n","protected":false},"excerpt":{"rendered":"<p>\uc990\uaca8\uc4f0\ub294 Command Queue \ubc29\uc2dd. Polling \ud558\ub294 Thread\ub97c \ub530\ub85c \ub450\uc9c0 \uc54a\ub294\ub2e4. Command Interface interface IExecutable { void Execute(); } Command Executer \/\/\/ \/\/\/ The executer with queue. \/\/\/ internal class ExecuterWithQueue { \/\/\/ \/\/\/ The is executing. \/\/\/ private bool isExecuting; \/\/\/ \/\/\/ The queue. \/\/\/ private ConcurrentQueue queue; \/\/\/ \/\/\/ Gets Queue. \/\/\/ private ConcurrentQueue [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"spay_email":""},"categories":[13,6],"tags":[480,67,77,79,87,207],"jetpack_featured_media_url":"","jetpack_sharing_enabled":true,"jetpack_shortlink":"https:\/\/wp.me\/pXV5a-wu","_links":{"self":[{"href":"https:\/\/talsu.net\/index.php?rest_route=\/wp\/v2\/posts\/2014"}],"collection":[{"href":"https:\/\/talsu.net\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/talsu.net\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/talsu.net\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/talsu.net\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=2014"}],"version-history":[{"count":0,"href":"https:\/\/talsu.net\/index.php?rest_route=\/wp\/v2\/posts\/2014\/revisions"}],"wp:attachment":[{"href":"https:\/\/talsu.net\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=2014"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/talsu.net\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=2014"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/talsu.net\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=2014"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}