并發(fā):
同一個對象對多個線程同時操作
線程同步:一種等待機制,等待前面線程使用完再下一個線程使用
線程同步形成條件:形成隊列,加上鎖機制(synchronized)
同步塊:synchronized(具體對象){代碼};鎖定資源,一個線程一個線程的使用
讓客戶滿意是我們工作的目標,不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領域值得信任、有價值的長期合作伙伴,公司提供的服務項目有:域名注冊、虛擬主機、營銷軟件、網站建設、公主嶺網站維護、網站推廣。
搶票:
public class n {
public static void main(String[]args) throws InterruptedException
{
web wb=new web();
new Thread(wb,"a").start();
new Thread(wb,"b").start();
new Thread(wb,"c").start();
}
}
class web implements Runnable{
int num=10;
private boolean flag=true;
public void run()
{
while(flag)
{
test();
}
}
public synchronized void test()//鎖的是對象的資源,即this成員,讓資源每次只被一個線程使用,然后下次靠cpu調度,而不讓
//一份資源同時被多個線程使用
{ if(num<0)
{
flag=false;
return;
}
try {
Thread.sleep(200);
}catch(InterruptedException e)
{
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"-->"+num--);
//線程不安全,可能都都是同一張票,可能票是負數
//負數:當還有1張票時,三個線程同時進入,都等待后,有兩個線程為負數
//相同票:線程有自己的工作臺,多個線程幾乎同時到達,拷貝數據
}
}
取錢:
public class el {
public static void main(String[]args)
{
account a=new account(100,"me");
get g=new get(a,80,"she");
get g2=new get(a,90,"he");
g.start();
g2.start();
}
}
//賬戶
class account {
int money;
String name;
public account(int money,String name)
{
this.money=money;
this.name=name;
}
}
//模擬取款
class get extends Thread
{
account a; //取錢的賬戶
int getmoney; //單個人取的錢數
int getall; //多個人取的總數
public get (account a,int getmoney,String name)
{
super(name);//Thread可以設置name
this.a=a;
this.getmoney=getmoney;
}
public void run()
{
test();
}
public /*synchronized */void test()//鎖定失敗,不應該鎖this,而應該鎖account
{//因為a.money是account里的,總錢數應該每次由一個線程調用,而不是多個線程
//使用同步塊鎖定
if(a.money<=0)
{
return;
}
synchronized(a){
if(a.money-getmoney<0) //添加也沒用
{
return;
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
a.money-=getmoney;
getall+=getmoney;
System.out.println(this.getName()+"-->賬戶余額為:"+a.money);
System.out.println(this.getName()+"-->取錢總數為:"+getall);
}
}
}
容器:
public class h {
public static void main(String[]args)
{
List<String> list=new ArrayList<String>();
for(int i=0;i<10000;i++)
{
new Thread(()->
{synchronized(list) {
list.add(Thread.currentThread().getName());}}
).start();
}
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(list.size());
}
}
新聞名稱:java多線程-改正不安全線程
文章地址:http://m.kartarina.com/article18/jedcgp.html
成都網站建設公司_創(chuàng)新互聯,為您提供響應式網站、網站導航、網站設計、微信公眾號、定制開發(fā)、網站維護
聲明:本網站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯