2017-06-12 29 views
1

我试图做一个工作列表I²C发送工作者。C#I²C发送器线程通过布线PIC

林saveing在ConCurrentQueue的I²C命令,并尝试通过wiringPi Libary

进出口新的线程和队列发送它,这就是为什么我无法弄清楚如何做到这一点的正确方法。

我想这一点,但它不会在所有的工作:d

将是很好,如果有人可以看看这一个告诉我什么即时做错了。

class worker 
{ 
    public bool enabled = false; 
    public struct i2c_command 
    { 
     public int chip_number; 
     public byte subadress; 
     public byte data; 
    } 

    private ConcurrentQueue<i2c_command> i2c_commandsList = new ConcurrentQueue<i2c_command>(); 

    public void write_i2c(int cn, byte sa, byte data) 
    { 
     i2c_command i2c_c = new i2c_command(); 
     i2c_c.chip_number = cn; 
     i2c_c.subadress = sa; 
     i2c_c.data = data; 
     i2c_commandsList.Enqueue(i2c_c); 
    } 

    public void i2c_worker() 
    { 
     enabled = true; 
     while (enabled = true) 
     { 
      i2c_command i2c_send = new i2c_command(); 
      i2c_commandsList.TryDequeue(out i2c_send); 

      WiringPi.I2C.wiringPiI2CWriteReg8(i2c_send.chip_number, i2c_send.subadress, i2c_send.data); 
     } 
    } 
} 

这是启动线程:

worker worker = new worker(); 
ThreadStart i2c_sender_ref = new ThreadStart(worker.i2c_worker); 
Thread i2c_sender = new Thread(i2c_sender_ref); 
i2c_sender.Start(); 
+0

您应该考虑在https://raspberrypi.stackexchange.com上发布此代码 –

+0

您可以在创建和启动线程的位置显示代码以执行I2C写入操作。 – PaulF

+0

我寻找的主要功能与树莓无关......我只是寻找ConcurrentQueue,我怎么可以在我的例子中使用它 –

回答

1

一开始,如果你从队列中得到一个命令你不检查 - 你的代码需要更多这样的:

public void i2c_worker() 
{ 
    enabled = true; 
    while (enabled) 
    { 
     i2c_command i2c_send; 
     if (i2c_commandsList.TryDequeue(out i2c_send)) 
      WiringPi.I2C.wiringPiI2CWriteReg8(i2c_send.chip_number, i2c_send.subadress, i2c_send.data); 
    } 
}