DevWiki/websocket-sharp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix a few for Example, Example1

Browse Source
This commit is contained in:
sta 2014-03-17 04:04:17 +09:00
parent a0ca1882d8
commit 73cd2cefce
3 changed files with 24 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
Example/Notifier.cs
View File

@ -12,20 +12,21 @@ namespace Example
{
private volatile bool _enabled;
private Queue<NotificationMessage> _queue;
private object _sync;
private ManualResetEvent _waitHandle;
public Notifier ()
{
_enabled = true;
_queue = new Queue<NotificationMessage> ();
_sync = ((ICollection) _queue).SyncRoot;
_waitHandle = new ManualResetEvent (false);
ThreadPool.QueueUserWorkItem (
state => {
while (_enabled || Count > 0) {
Thread.Sleep (500);
if (Count > 0) {
var msg = dequeue ();
var msg = dequeue ();
if (msg != null) {
#if UBUNTU
var nf = new Notification (msg.Summary, msg.Body, msg.Icon);
nf.AddHint ("append", "allowed");
@ -34,6 +35,8 @@ namespace Example
Console.WriteLine (msg);
#endif
}
else
Thread.Sleep (500);
}
_waitHandle.Set ();
@ -42,7 +45,7 @@ namespace Example
public int Count {
get {
lock (((ICollection) _queue).SyncRoot) {
lock (_sync) {
return _queue.Count;
}
}
@ -50,8 +53,10 @@ namespace Example
private NotificationMessage dequeue ()
{
lock (((ICollection) _queue).SyncRoot) {
return _queue.Dequeue ();
lock (_sync) {
return _queue.Count > 0
? _queue.Dequeue ()
: null;
}
}
@ -64,7 +69,7 @@ namespace Example
public void Notify (NotificationMessage message)
{
lock (((ICollection) _queue).SyncRoot) {
lock (_sync) {
if (_enabled)
_queue.Enqueue (message);
}

19
Example1/Notifier.cs
View File

@ -12,20 +12,21 @@ namespace Example1
{
private volatile bool _enabled;
private Queue<NotificationMessage> _queue;
private object _sync;
private ManualResetEvent _waitHandle;
public Notifier ()
{
_enabled = true;
_queue = new Queue<NotificationMessage> ();
_sync = ((ICollection) _queue).SyncRoot;
_waitHandle = new ManualResetEvent (false);
ThreadPool.QueueUserWorkItem (
state => {
while (_enabled || Count > 0) {
Thread.Sleep (500);
if (Count > 0) {
var msg = dequeue ();
var msg = dequeue ();
if (msg != null) {
#if UBUNTU
var nf = new Notification (msg.Summary, msg.Body, msg.Icon);
nf.AddHint ("append", "allowed");
@ -34,6 +35,8 @@ namespace Example1
Console.WriteLine (msg);
#endif
}
else
Thread.Sleep (500);
}
_waitHandle.Set ();
@ -42,7 +45,7 @@ namespace Example1
public int Count {
get {
lock (((ICollection) _queue).SyncRoot) {
lock (_sync) {
return _queue.Count;
}
}
@ -50,8 +53,10 @@ namespace Example1
private NotificationMessage dequeue ()
{
lock (((ICollection) _queue).SyncRoot) {
return _queue.Dequeue ();
lock (_sync) {
return _queue.Count > 0
? _queue.Dequeue ()
: null;
}
}
@ -64,7 +69,7 @@ namespace Example1
public void Notify (NotificationMessage message)
{
lock (((ICollection) _queue).SyncRoot) {
lock (_sync) {
if (_enabled)
_queue.Enqueue (message);
}

1
Example1/Program.cs
View File

@ -18,7 +18,6 @@ namespace Example1
while (name.Length == 0);
streamer.Connect (name);
Console.WriteLine ("\nType \"exit\" to exit.\n");
while (true) {
Thread.Sleep (1000);