#include
using namespace std;
template
typedef typename std::queue<T, Container> queue_t;
typedef typename queue_t::value_type value_type;
protected:
queue_t m_queue;
pthread_mutex_t m_mutex;
public:
terra_spin_queue()
{
pthread_mutex_init(&m_mutex, NULL);
}
~terra_spin_queue()
{
pthread_mutex_destroy(&m_mutex);
}
void push(const value_type& value)
{
pthread_mutex_lock(&m_mutex);
m_queue.push(value);
pthread_mutex_unlock(&m_mutex);
}
bool try_pop(value_type& result)
{
pthread_mutex_lock(&m_mutex);
if (!m_queue.empty())
{
result = m_queue.front();
m_queue.pop();
pthread_mutex_unlock(&m_mutex);
return true;
}
else
{
pthread_mutex_unlock(&m_mutex);
return false;
}
}
};
struct ttt {
char a[12];
int b;
};
static terra_spin_queue
void* workTrheadFunc(void* arg) {
int v=0;
while (true)
{
ttt *val=new ttt;
val->b=v++;
global_queue.push(val);
// usleep(1);
}
return 0;
}
int main() {
pthread_t log_tid;
pthread_attr_t attr;
pthread_attr_init(&attr);
const size_t stack_size = 10 * 1024 * 1024 * 1024;
pthread_attr_setstacksize(&attr, stack_size);
pthread_create(&log_tid, &attr, workTrheadFunc,NULL);
while (true)
{
ttt *i;
if(global_queue.try_pop(i))
{
cout << "Consumer: " << i->b << endl;
delete i;
i=nullptr;
}
}
return 0;
}
![/data # iw --debug dev wlan0 connect -w "lucky-5g" auth open key 0:1234567890
Usage: iw [options] dev connect [-w] [] [] [auth open|shared] [key 0:abcde d:1:6162636465] [mfp:req/opt/no]
Join the network with ...](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162239148267954.png)
![驱动代码
void kalRxTaskletSchedule(struct GLUE_INFO *pr)
{
static unsigned int num = 0;
tasklet_hi_schedule(&pr->rRxTask[(num++)%NR_CPUS]);
// tasklet_hi_schedule(&pr->rRxTask);
DBGLOG(HAL, ERROR,](https://linuxcpp.0voice.com/zb_users/upload/2023/05/202305162226144313964.png)
